import { Inject, Provide, Get } from '@midwayjs/core';
import { CoolController, BaseController } from '@cool-midway/core';
import { DemoRpcService } from '../../service/rpc';

/**
 * 远程RPC调用
 */
@CoolController()
export class OpenDemoRpcController extends BaseController {
  @Inject()
  demoRpcService: DemoRpcService;

  @Get('/call', { summary: '远程调用' })
  async call() {
    return this.ok(await this.demoRpcService.call());
  }

  @Get('/event', { summary: '集群事件' })
  async event() {
    await this.demoRpcService.event();
    return this.ok();
  }

  @Get('/transaction', { summary: '分布式事务' })
  async transaction() {
    await this.demoRpcService.transaction({ a: 1 });
    return this.ok();
  }
}