+++ /dev/null
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * 'License'); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * 'AS IS' BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-//This is the server side Node test handler for the standard
-// Apache Thrift test service.
-
-import ttypes = require("./gen-nodejs/ThriftTest_types");
-import thrift = require("thrift");
-import Thrift = thrift.Thrift;
-import Q = require("q");
-import Int64 = require("node-int64");
-
-
-export class SyncThriftTestHandler {
- testVoid(): Q.IPromise<void> {
- //console.log('testVoid()');
- return Q.resolve<void>(undefined);
- }
- testMapMap(hello: number) {
- //console.log('testMapMap(' + hello + ')');
-
- var mapmap: {[key: number]: {[key: number]: number; }} = [];
- var pos: {[key: number]: number; } = [];
- var neg: {[key: number]: number; } = [];
- for (var i = 1; i < 5; i++) {
- pos[i] = i;
- neg[-i] = -i;
- }
- mapmap[4] = pos;
- mapmap[-4] = neg;
-
- return Q.resolve(mapmap);
- }
- testInsanity(argument: ttypes.Insanity): Q.IPromise<{ [k: number]: any; }> {
- const first_map: { [k: number]: any; } = [];
- const second_map: { [k: number]: any; } = [];
-
- first_map[ttypes.Numberz.TWO] = argument;
- first_map[ttypes.Numberz.THREE] = argument;
-
- const looney = new ttypes.Insanity();
- second_map[ttypes.Numberz.SIX] = looney;
-
- const insane: { [k: number]: any; } = [];
- insane[1] = first_map;
- insane[2] = second_map;
-
- return Q.resolve(insane);
- }
- testMulti(arg0: any, arg1: number, arg2: Int64, arg3: { [k: number]: string; }, arg4: ttypes.Numberz, arg5: number) {
- var hello = new ttypes.Xtruct();
- hello.string_thing = 'Hello2';
- hello.byte_thing = arg0;
- hello.i32_thing = arg1;
- hello.i64_thing = arg2;
- return Q.resolve(hello);
- }
- testException(arg: string): Q.IPromise<void> {
- if (arg === 'Xception') {
- var x = new ttypes.Xception();
- x.errorCode = 1001;
- x.message = arg;
- throw x;
- } else if (arg === 'TException') {
- throw new Thrift.TException(arg);
- } else {
- return Q.resolve();
- }
- }
- testMultiException(arg0: string, arg1: string) {
- if (arg0 === ('Xception')) {
- var x = new ttypes.Xception();
- x.errorCode = 1001;
- x.message = 'This is an Xception';
- throw x;
- } else if (arg0 === ('Xception2')) {
- var x2 = new ttypes.Xception2();
- x2.errorCode = 2002;
- x2.struct_thing = new ttypes.Xtruct();
- x2.struct_thing.string_thing = 'This is an Xception2';
- throw x2;
- }
-
- var res = new ttypes.Xtruct();
- res.string_thing = arg1;
- return Q.resolve(res);
- }
- testOneway(sleepFor: number) {
- }
-
- testString(thing: string) {
- return Q.resolve(thing);
- }
- testBool(thing: boolean) {
- return Q.resolve(thing);
- }
- testByte(thing: number) {
- return Q.resolve(thing);
- }
- testI32(thing: number) {
- return Q.resolve(thing);
- }
- testI64(thing: number) {
- return Q.resolve(thing);
- }
- testDouble(thing: number) {
- return Q.resolve(thing);
- }
- testBinary(thing: Buffer) {
- return Q.resolve(thing);
- }
- testStruct(thing: ttypes.Xtruct) {
- return Q.resolve(thing);
- }
- testNest(thing: ttypes.Xtruct2) {
- return Q.resolve(thing);
- }
- testMap(thing: { [k: number]: number; }) {
- return Q.resolve(thing);
- }
- testStringMap(thing: { [k: string]: string; }) {
- return Q.resolve(thing);
- }
- testSet(thing: number[]) {
- return Q.resolve(thing);
- }
- testList(thing: number[]) {
- return Q.resolve(thing);
- }
- testEnum(thing: ttypes.Numberz) {
- return Q.resolve(thing);
- }
- testTypedef(thing: number) {
- return Q.resolve(thing);
- }
-}
-
-export class AsyncThriftTestHandler {
- private syncHandler: SyncThriftTestHandler;
- constructor() {
- this.syncHandler = new SyncThriftTestHandler();
- }
-
- testVoid(callback: (result: void) => void): Q.IPromise<void> {
- callback(undefined);
- return Q.resolve();
- }
- testMapMap(hello: number,
- callback: (err: any, result: { [k: number]: { [k: number]: number; }; }) => void):
- Q.IPromise<{ [k: number]: { [k: number]: number; }; }> {
-
- var mapmap: {[key: number]: {[key: number]: number; }} = [];
- var pos: {[key: number]: number; } = [];
- var neg: {[key: number]: number; } = [];
- for (var i = 1; i < 5; i++) {
- pos[i] = i;
- neg[-i] = -i;
- }
- mapmap[4] = pos;
- mapmap[-4] = neg;
-
- callback(null, mapmap);
- return Q.resolve();
- }
- testInsanity(argument: ttypes.Insanity, callback?: (err: any, result: { [k: number]: any; }) => void): Q.IPromise<{ [k: number]: any; }> {
- const first_map: { [k: number]: any; } = [];
- const second_map: { [k: number]: any; } = [];
-
- first_map[ttypes.Numberz.TWO] = argument;
- first_map[ttypes.Numberz.THREE] = argument;
-
- const looney = new ttypes.Insanity();
- second_map[ttypes.Numberz.SIX] = looney;
-
- const insane: { [k: number]: any; } = [];
- insane[1] = first_map;
- insane[2] = second_map;
-
- if (callback !== undefined){
- callback(null, insane);
- }
- return Q.resolve();
- }
- testMulti(arg0: any, arg1: number, arg2: Int64, arg3: { [k: number]: string; }, arg4: ttypes.Numberz, arg5: number, result: Function): Q.IPromise<ttypes.Xtruct> {
- var hello = this.syncHandler.testMulti(arg0, arg1, arg2, arg3, arg4, arg5);
- hello.then(hello => result(null, hello));
- return Q.resolve();
- }
- testException(arg: string, result: (err: any) => void): Q.IPromise<void> {
- if (arg === 'Xception') {
- var x = new ttypes.Xception();
- x.errorCode = 1001;
- x.message = arg;
- result(x);
- } else if (arg === 'TException') {
- result(new Thrift.TException(arg));
- } else {
- result(null);
- }
- return Q.resolve();
- }
- testMultiException(arg0: string, arg1: string, result: (err: any, res?: ttypes.Xtruct) => void): Q.IPromise<ttypes.Xtruct> {
- if (arg0 === ('Xception')) {
- var x = new ttypes.Xception();
- x.errorCode = 1001;
- x.message = 'This is an Xception';
- result(x);
- } else if (arg0 === ('Xception2')) {
- var x2 = new ttypes.Xception2();
- x2.errorCode = 2002;
- x2.struct_thing = new ttypes.Xtruct();
- x2.struct_thing.string_thing = 'This is an Xception2';
- result(x2);
- } else {
- var res = new ttypes.Xtruct();
- res.string_thing = arg1;
- result(null, res);
- }
- return Q.resolve();
- }
- testOneway(sleepFor: number, result: Function) {
- this.syncHandler.testOneway(sleepFor);
- }
- testString(thing: string, callback: (err: any, result: string) => void): Q.IPromise<string> {
- callback(null, thing);
- return Q.resolve();
- }
- testByte(thing: number, callback: (err: any, result: number) => void): Q.IPromise<number> {
- callback(null, thing);
- return Q.resolve();
- }
- testBool(thing: boolean, callback: (err: any, result: boolean) => void ): Q.IPromise<boolean> {
- callback(null, thing);
- return Q.resolve();
- }
- testI32(thing: number, callback: (err: any, result: number) => void): Q.IPromise<number> {
- callback(null, thing);
- return Q.resolve();
- }
- testI64(thing: number, callback: (err: any, result: number) => void): Q.IPromise<number> {
- callback(null, thing);
- return Q.resolve();
- }
- testDouble(thing: number, callback: (err: any, result: number) => void): Q.IPromise<number> {
- callback(null, thing);
- return Q.resolve();
- }
- testBinary(thing: Buffer, callback: (err: any, result: Buffer) => void): Q.IPromise<Buffer> {
- callback(null, thing);
- return Q.resolve();
- }
- testStruct(thing: ttypes.Xtruct, callback: (err: any, result: ttypes.Xtruct) => void): Q.IPromise<ttypes.Xtruct> {
- callback(null, thing);
- return Q.resolve();
- }
- testNest(thing: ttypes.Xtruct2, callback: (err: any, result: ttypes.Xtruct2) => void): Q.IPromise<ttypes.Xtruct2> {
- callback(null, thing);
- return Q.resolve();
- }
- testMap(thing: { [k: number]: number; }, callback: (err: any, result: { [k: number]: number; }) => void): Q.IPromise<{ [k: number]: number; }> {
- callback(null, thing);
- return Q.resolve();
- }
- testStringMap(thing: { [k: string]: string; }, callback: (err: any, result: { [k: string]: string; }) => void): Q.IPromise<{ [k: string]: string; }> {
- callback(null, thing);
- return Q.resolve();
- }
- testSet(thing: number[], callback: (err: any, result: number[]) => void): Q.IPromise<number[]> {
- callback(null, thing);
- return Q.resolve();
- }
- testList(thing: number[], callback: (err: any, result: number[]) => void): Q.IPromise<number[]> {
- callback(null, thing);
- return Q.resolve();
- }
- testEnum(thing: ttypes.Numberz, callback: (err: any, result: ttypes.Numberz) => void): Q.IPromise<ttypes.Numberz> {
- callback(null, thing);
- return Q.resolve();
- }
- testTypedef(thing: number, callback: (err: any, result: number) => void): Q.IPromise<number> {
- callback(null, thing);
- return Q.resolve();
- }
-}
projects / ceph.git / blobdiff