Skip to content

Commit

Permalink
ci: debug
Browse files Browse the repository at this point in the history
  • Loading branch information
@waitingsong
waitingsong committed Nov 9, 2024
1 parent 7a17a3c commit 288b3dd
Showing 1 changed file with 177 additions and 177 deletions.
354 changes: 177 additions & 177 deletions packages/grpc/test/index.test.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -79,47 +79,47 @@ export namespace math {

describe('/test/index.test.ts', function () {

it('run with empty config', async () => {
const app = await createServer('base-app-empty');
await closeApp(app);
});

it('should create gRPC server', async () => {
const app = await createServer('base-app');

const service = await createGRPCConsumer<helloworld.GreeterClient>({
package: 'helloworld',
protoPath: join(__dirname, 'fixtures/proto/helloworld.proto'),
url: 'localhost:6565'
});

const meta = new Metadata();
meta.add('key', 'value');

const result = await service.sayHello({
metadata: meta,
}).sendMessage({
name: 'harry'
});

expect(result).toEqual({ message: 'Hello harry' });

const serverMetadata = await new Promise<Metadata>((resolve, reject) => {
const call = service.sayHello().sendMessageWithCallback({
name: 'zhangting'
}, (err) => {
if (err) {
reject(err);
}
});
call.on('metadata', (meta) => {
resolve(meta);
});
})

expect(serverMetadata.get('Set-Cookie')[0]).toEqual('yummy_cookie=choco');
await closeApp(app);
});
// it('run with empty config', async () => {
// const app = await createServer('base-app-empty');
// await closeApp(app);
// });

// it('should create gRPC server', async () => {
// const app = await createServer('base-app');

// const service = await createGRPCConsumer<helloworld.GreeterClient>({
// package: 'helloworld',
// protoPath: join(__dirname, 'fixtures/proto/helloworld.proto'),
// url: 'localhost:6565'
// });

// const meta = new Metadata();
// meta.add('key', 'value');

// const result = await service.sayHello({
// metadata: meta,
// }).sendMessage({
// name: 'harry'
// });

// expect(result).toEqual({ message: 'Hello harry' });

// const serverMetadata = await new Promise<Metadata>((resolve, reject) => {
// const call = service.sayHello().sendMessageWithCallback({
// name: 'zhangting'
// }, (err) => {
// if (err) {
// reject(err);
// }
// });
// call.on('metadata', (meta) => {
// resolve(meta);
// });
// })

// expect(serverMetadata.get('Set-Cookie')[0]).toEqual('yummy_cookie=choco');
// await closeApp(app);
// });

it('should create multiple grpc service in one server', async () => {
const app = await createServer('base-app-multiple-service');
Expand All @@ -134,140 +134,140 @@ describe('/test/index.test.ts', function () {
await closeApp(app);
});

it('should create multiple grpc service in one server 2', async () => {
const app = await createServer('base-app-multiple-service-2');
const opts = {
package: 'hero2',
protoPath: join(__dirname, 'fixtures/proto/hero2.proto'),
url: 'localhost:6566'
}

const service = await createGRPCConsumer<hero2.HeroServiceClient>({ ...opts, });
const result = await service.findOne().sendMessage({ id: 123 });
expect(result).toEqual({ id: 1, name: 'bbbb-Hello harry' })

const service2 = await createGRPCConsumer<hero2.HeroService2Client>({ service: 'HeroService2', ...opts, });
const result2 = await service2.findOne2().sendMessage({ id: 123 });
expect(result2).toEqual({ id: 1, name: 'bbbb-Hello harry' })

const service3 = await createGRPCConsumer<hero2.HeroService2Client>({ ...opts, service: 'hero2.HeroService2' });
const result3 = await service3.findOne2().sendMessage({ id: 123 });
expect(result3).toEqual({ id: 1, name: 'bbbb-Hello harry' })
await closeApp(app);
});

it('should support publish stream gRPC server', async () => {
const app = await createServer('base-app-stream');

const service = await createGRPCConsumer<math.MathClient>({
package: 'math',
protoPath: join(__dirname, 'fixtures/proto/math.proto'),
url: 'localhost:6568'
});

// 使用发送消息的写法
let result1 = await service.add().sendMessage({
num: 2,
});

expect(result1.num).toEqual(4);

// 服务端推送
let total = 0;
let result2 = await service.sumMany().sendMessage({
num: 1,
});

result2.forEach(data => {
total += data.num;
});

expect(total).toEqual(9);

// 客户端推送
const data = await service.addMany()
.sendMessage({num: 1})
.sendMessage({num: 2})
.sendMessage({num: 3})
.end();

expect(data.num).toEqual(6);

// 双向流
const result3= await new Promise<number>((resolve, reject) => {
const duplexCall = service.addMore().getCall();
total = 0;
let idx = 0;

duplexCall.on('data', (data: math.Num) => {
total += data.num;
idx++;
if (idx === 2) {
duplexCall.end();
resolve(total);
}
});

duplexCall.write({
num: 3,
});

duplexCall.write({
num: 6,
});
});

expect(result3).toEqual(29);


// 保证顺序的双向流
const t = service.addMore({
messageKey: 'id'
});

const result4 = await new Promise<number>((resolve, reject) => {
total = 0;
t.sendMessage({
num: 2
})
.then(res => {
expect(res.num).toEqual(12);
total += res.num;
})
.catch(err => console.error(err))
;
t.sendMessage({
num: 5
})
.then(res => {
expect(res.num).toEqual(15);
total += res.num;
resolve(total);
})
.catch(err => console.error(err))
;
t.end();
});

expect(result4).toEqual(27);

await closeApp(app);
});

it('should test multi-package service', async () => {
const app = await createServer('base-app-multiple-package');

const service = await createGRPCConsumer<hello.world.GreeterClient>({
package: 'hello.world',
protoPath: join(__dirname, 'fixtures/proto/hello_world.proto'),
url: 'localhost:6569'
});

const result = await service.sayHello().sendMessage({
name: 'harry'
});

expect(result).toEqual({ message: 'Hello harry' });
await closeApp(app);
});
// it('should create multiple grpc service in one server 2', async () => {
// const app = await createServer('base-app-multiple-service-2');
// const opts = {
// package: 'hero2',
// protoPath: join(__dirname, 'fixtures/proto/hero2.proto'),
// url: 'localhost:6566'
// }

// const service = await createGRPCConsumer<hero2.HeroServiceClient>({ ...opts, });
// const result = await service.findOne().sendMessage({ id: 123 });
// expect(result).toEqual({ id: 1, name: 'bbbb-Hello harry' })

// const service2 = await createGRPCConsumer<hero2.HeroService2Client>({ service: 'HeroService2', ...opts, });
// const result2 = await service2.findOne2().sendMessage({ id: 123 });
// expect(result2).toEqual({ id: 1, name: 'bbbb-Hello harry' })

// const service3 = await createGRPCConsumer<hero2.HeroService2Client>({ ...opts, service: 'hero2.HeroService2' });
// const result3 = await service3.findOne2().sendMessage({ id: 123 });
// expect(result3).toEqual({ id: 1, name: 'bbbb-Hello harry' })
// await closeApp(app);
// });

// it('should support publish stream gRPC server', async () => {
// const app = await createServer('base-app-stream');

// const service = await createGRPCConsumer<math.MathClient>({
// package: 'math',
// protoPath: join(__dirname, 'fixtures/proto/math.proto'),
// url: 'localhost:6568'
// });

// // 使用发送消息的写法
// let result1 = await service.add().sendMessage({
// num: 2,
// });

// expect(result1.num).toEqual(4);

// // 服务端推送
// let total = 0;
// let result2 = await service.sumMany().sendMessage({
// num: 1,
// });

// result2.forEach(data => {
// total += data.num;
// });

// expect(total).toEqual(9);

// // 客户端推送
// const data = await service.addMany()
// .sendMessage({num: 1})
// .sendMessage({num: 2})
// .sendMessage({num: 3})
// .end();

// expect(data.num).toEqual(6);

// // 双向流
// const result3= await new Promise<number>((resolve, reject) => {
// const duplexCall = service.addMore().getCall();
// total = 0;
// let idx = 0;

// duplexCall.on('data', (data: math.Num) => {
// total += data.num;
// idx++;
// if (idx === 2) {
// duplexCall.end();
// resolve(total);
// }
// });

// duplexCall.write({
// num: 3,
// });

// duplexCall.write({
// num: 6,
// });
// });

// expect(result3).toEqual(29);


// // 保证顺序的双向流
// const t = service.addMore({
// messageKey: 'id'
// });

// const result4 = await new Promise<number>((resolve, reject) => {
// total = 0;
// t.sendMessage({
// num: 2
// })
// .then(res => {
// expect(res.num).toEqual(12);
// total += res.num;
// })
// .catch(err => console.error(err))
// ;
// t.sendMessage({
// num: 5
// })
// .then(res => {
// expect(res.num).toEqual(15);
// total += res.num;
// resolve(total);
// })
// .catch(err => console.error(err))
// ;
// t.end();
// });

// expect(result4).toEqual(27);

// await closeApp(app);
// });

// it('should test multi-package service', async () => {
// const app = await createServer('base-app-multiple-package');

// const service = await createGRPCConsumer<hello.world.GreeterClient>({
// package: 'hello.world',
// protoPath: join(__dirname, 'fixtures/proto/hello_world.proto'),
// url: 'localhost:6569'
// });

// const result = await service.sayHello().sendMessage({
// name: 'harry'
// });

// expect(result).toEqual({ message: 'Hello harry' });
// await closeApp(app);
// });
});

0 comments on commit 288b3dd

Please sign in to comment.