controllerbus/bus/api/api_srpc.pb.ts at master · aperturerobotics/controllerbus · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
// @generated by protoc-gen-es-starpc none with parameter "target=ts,ts_nocheck=false"
// @generated from file github.com/aperturerobotics/controllerbus/bus/api/api.proto (package bus.api, syntax proto3)
/* eslint-disable */

import { GetBusInfoRequest, GetBusInfoResponse } from './api.pb.js'
import { MethodKind } from '@aptre/protobuf-es-lite'
import {
  ExecControllerRequest,
  ExecControllerResponse,
} from '../../controller/exec/exec.pb.js'
import { buildDecodeMessageTransform, MessageStream, ProtoRpc } from 'starpc'

/**
 * ControllerBusService is a generic controller bus lookup api.
 *
 * @generated from service bus.api.ControllerBusService
 */
export const ControllerBusServiceDefinition = {
  typeName: 'bus.api.ControllerBusService',
  methods: {
    /**
     * GetBusInfo requests information about the controller bus.
     *
     * @generated from rpc bus.api.ControllerBusService.GetBusInfo
     */
    GetBusInfo: {
      name: 'GetBusInfo',
      I: GetBusInfoRequest,
      O: GetBusInfoResponse,
      kind: MethodKind.Unary,
    },
    /**
     * ExecController executes a controller configuration on the bus.
     *
     * @generated from rpc bus.api.ControllerBusService.ExecController
     */
    ExecController: {
      name: 'ExecController',
      I: ExecControllerRequest,
      O: ExecControllerResponse,
      kind: MethodKind.ServerStreaming,
    },
  },
} as const

/**
 * ControllerBusService is a generic controller bus lookup api.
 *
 * @generated from service bus.api.ControllerBusService
 */
export interface ControllerBusService {
  /**
   * GetBusInfo requests information about the controller bus.
   *
   * @generated from rpc bus.api.ControllerBusService.GetBusInfo
   */
  GetBusInfo(
    request: GetBusInfoRequest,
    abortSignal?: AbortSignal,
  ): Promise<GetBusInfoResponse>

  /**
   * ExecController executes a controller configuration on the bus.
   *
   * @generated from rpc bus.api.ControllerBusService.ExecController
   */
  ExecController(
    request: ExecControllerRequest,
    abortSignal?: AbortSignal,
  ): MessageStream<ExecControllerResponse>
}

export const ControllerBusServiceServiceName =
  ControllerBusServiceDefinition.typeName

export class ControllerBusServiceClient implements ControllerBusService {
  private readonly rpc: ProtoRpc
  private readonly service: string
  constructor(rpc: ProtoRpc, opts?: { service?: string }) {
    this.service = opts?.service || ControllerBusServiceServiceName
    this.rpc = rpc
    this.GetBusInfo = this.GetBusInfo.bind(this)
    this.ExecController = this.ExecController.bind(this)
  }
  /**
   * GetBusInfo requests information about the controller bus.
   *
   * @generated from rpc bus.api.ControllerBusService.GetBusInfo
   */
  async GetBusInfo(
    request: GetBusInfoRequest,
    abortSignal?: AbortSignal,
  ): Promise<GetBusInfoResponse> {
    const requestMsg = GetBusInfoRequest.create(request)
    const result = await this.rpc.request(
      this.service,
      ControllerBusServiceDefinition.methods.GetBusInfo.name,
      GetBusInfoRequest.toBinary(requestMsg),
      abortSignal || undefined,
    )
    return GetBusInfoResponse.fromBinary(result)
  }

  /**
   * ExecController executes a controller configuration on the bus.
   *
   * @generated from rpc bus.api.ControllerBusService.ExecController
   */
  ExecController(
    request: ExecControllerRequest,
    abortSignal?: AbortSignal,
  ): MessageStream<ExecControllerResponse> {
    const requestMsg = ExecControllerRequest.create(request)
    const result = this.rpc.serverStreamingRequest(
      this.service,
      ControllerBusServiceDefinition.methods.ExecController.name,
      ExecControllerRequest.toBinary(requestMsg),
      abortSignal || undefined,
    )
    return buildDecodeMessageTransform(ExecControllerResponse)(result)
  }
}