// This file is auto-generated, don't edit it
/**
 */
import Util, * as $Util from '@alicloud/tea-util';
import GatewayClient from '@alicloud/gateway-dingtalk';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import OpenApiUtil from '@alicloud/openapi-util';
import * as $tea from '@alicloud/tea-typescript';

export class OpenConnectionRequest extends $tea.Model {
  /**
   * @remarks
   * This parameter is required.
   * 
   * @example
   * suiteudabcd123
   */
  clientId?: string;
  /**
   * @remarks
   * This parameter is required.
   * 
   * @example
   * 9W1berqrwfs
   */
  clientSecret?: string;
  extras?: { [key: string]: any };
  /**
   * @example
   * 32.78.48.10
   */
  localIp?: string;
  /**
   * @remarks
   * This parameter is required.
   */
  subscriptions?: OpenConnectionRequestSubscriptions[];
  static names(): { [key: string]: string } {
    return {
      clientId: 'clientId',
      clientSecret: 'clientSecret',
      extras: 'extras',
      localIp: 'localIp',
      subscriptions: 'subscriptions',
    };
  }

  static types(): { [key: string]: any } {
    return {
      clientId: 'string',
      clientSecret: 'string',
      extras: { 'type': 'map', 'keyType': 'string', 'valueType': 'any' },
      localIp: 'string',
      subscriptions: { 'type': 'array', 'itemType': OpenConnectionRequestSubscriptions },
    };
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class OpenConnectionResponseBody extends $tea.Model {
  /**
   * @example
   * wss://open-connection.dingtalk.com/connect
   */
  endpoint?: string;
  /**
   * @example
   * 67e5aeb3-de99-11ed-897e-e251245ed5d2
   */
  ticket?: string;
  static names(): { [key: string]: string } {
    return {
      endpoint: 'endpoint',
      ticket: 'ticket',
    };
  }

  static types(): { [key: string]: any } {
    return {
      endpoint: 'string',
      ticket: 'string',
    };
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class OpenConnectionResponse extends $tea.Model {
  headers?: { [key: string]: string };
  statusCode?: number;
  body?: OpenConnectionResponseBody;
  static names(): { [key: string]: string } {
    return {
      headers: 'headers',
      statusCode: 'statusCode',
      body: 'body',
    };
  }

  static types(): { [key: string]: any } {
    return {
      headers: { 'type': 'map', 'keyType': 'string', 'valueType': 'string' },
      statusCode: 'number',
      body: OpenConnectionResponseBody,
    };
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}

export class OpenConnectionRequestSubscriptions extends $tea.Model {
  /**
   * @remarks
   * This parameter is required.
   * 
   * @example
   * /v1.0/im/bot/messages/get
   */
  topic?: string;
  /**
   * @remarks
   * This parameter is required.
   * 
   * @example
   * EVENT
   */
  type?: string;
  static names(): { [key: string]: string } {
    return {
      topic: 'topic',
      type: 'type',
    };
  }

  static types(): { [key: string]: any } {
    return {
      topic: 'string',
      type: 'string',
    };
  }

  constructor(map?: { [key: string]: any }) {
    super(map);
  }
}


export default class Client extends OpenApi {

  constructor(config: $OpenApi.Config) {
    super(config);
    let gatewayClient = new GatewayClient();
    this._spi = gatewayClient;
    this._endpointRule = "";
    if (Util.empty(this._endpoint)) {
      this._endpoint = "api.dingtalk.com";
    }

  }


  /**
   * 云上网关注册长连接
   * 
   * @param request - OpenConnectionRequest
   * @param headers - map
   * @param runtime - runtime options for this request RuntimeOptions
   * @returns OpenConnectionResponse
   */
  async openConnectionWithOptions(request: OpenConnectionRequest, headers: {[key: string ]: string}, runtime: $Util.RuntimeOptions): Promise<OpenConnectionResponse> {
    Util.validateModel(request);
    let body : {[key: string ]: any} = { };
    if (!Util.isUnset(request.clientId)) {
      body["clientId"] = request.clientId;
    }

    if (!Util.isUnset(request.clientSecret)) {
      body["clientSecret"] = request.clientSecret;
    }

    if (!Util.isUnset(request.extras)) {
      body["extras"] = request.extras;
    }

    if (!Util.isUnset(request.localIp)) {
      body["localIp"] = request.localIp;
    }

    if (!Util.isUnset(request.subscriptions)) {
      body["subscriptions"] = request.subscriptions;
    }

    let req = new $OpenApi.OpenApiRequest({
      headers: headers,
      body: OpenApiUtil.parseToMap(body),
    });
    let params = new $OpenApi.Params({
      action: "OpenConnection",
      version: "gateway_1.0",
      protocol: "HTTP",
      pathname: `/v1.0/gateway/connections/open`,
      method: "POST",
      authType: "Anonymous",
      style: "ROA",
      reqBodyType: "none",
      bodyType: "json",
    });
    return $tea.cast<OpenConnectionResponse>(await this.execute(params, req, runtime), new OpenConnectionResponse({}));
  }

  /**
   * 云上网关注册长连接
   * 
   * @param request - OpenConnectionRequest
   * @returns OpenConnectionResponse
   */
  async openConnection(request: OpenConnectionRequest): Promise<OpenConnectionResponse> {
    let runtime = new $Util.RuntimeOptions({ });
    let headers : {[key: string ]: string} = { };
    return await this.openConnectionWithOptions(request, headers, runtime);
  }

}