operations_protocol.http.dart

import 'dart:convert';

import 'package:celest_cloud/src/cloud/base/base_protocol.dart';
import 'package:celest_cloud/src/cloud/cloud.dart';
import 'package:celest_cloud/src/cloud/operations/operations_protocol.dart';
import 'package:celest_cloud/src/proto/google/longrunning/operations.pb.dart';
import 'package:celest_core/_internal.dart';
import 'package:http/http.dart' as http;

final class OperationsProtocolHttp
    with BaseProtocol
    implements OperationsProtocol {
  OperationsProtocolHttp({
    required Uri uri,
    http.Client? httpClient,
  })  : _client = httpClient ?? http.Client(),
        _baseUri = uri;

  final http.Client _client;
  final Uri _baseUri;

  @override
  Future<void> cancel(CancelOperationRequest request) async {
    final path = '/v1alpha1/${request.name}:cancel';
    final url = _baseUri.replace(path: path);
    final req = http.Request('POST', url)
      ..body = jsonEncode(
        request.toProto3Json(
          typeRegistry: CelestCloud.typeRegistry,
        ),
      )
      ..headers['content-type'] = 'application/json'
      ..headers['accept'] = 'application/json';
    final res = await _client.send(req);
    if (res.statusCode != 200) {
      final body = await res.stream.toBytes();
      throwError(
        statusCode: res.statusCode,
        bodyBytes: body,
      );
    }
  }

  @override
  Future<Operation> get(GetOperationRequest request) async {
    final path = '/v1alpha1/${request.name}';
    final url = _baseUri.replace(path: path);
    final req = http.Request('GET', url)
      ..headers['content-type'] = 'application/json'
      ..headers['accept'] = 'application/json';
    final res = await _client.send(req);
    final body = await res.stream.toBytes();
    if (res.statusCode != 200) {
      throwError(
        statusCode: res.statusCode,
        bodyBytes: body,
      );
    }
    return Operation()
      ..mergeFromProto3Json(
        JsonUtf8.decode(body),
        typeRegistry: CelestCloud.typeRegistry,
      );
  }

  @override
  Future<ListOperationsResponse> list(ListOperationsRequest request) async {
    if (request.name == '') {
      throw ArgumentError.value(request.name, 'name', 'must not be empty');
    }
    final path = '/v1alpha1/${request.name}/operations';
    final url = _baseUri.replace(
      path: path,
      queryParameters: {
        if (request.hasFilter()) 'filter': request.filter,
        if (request.hasPageSize()) 'pageSize': request.pageSize.toString(),
        if (request.hasPageToken()) 'pageToken': request.pageToken,
      },
    );
    final req = http.Request('GET', url)
      ..headers['content-type'] = 'application/json'
      ..headers['accept'] = 'application/json';
    final res = await _client.send(req);
    final body = await res.stream.toBytes();
    if (res.statusCode != 200) {
      throwError(
        statusCode: res.statusCode,
        bodyBytes: body,
      );
    }
    return ListOperationsResponse()
      ..mergeFromProto3Json(
        JsonUtf8.decode(body),
        typeRegistry: CelestCloud.typeRegistry,
      );
  }

  @override
  Future<Operation> wait(WaitOperationRequest request) async {
    if (request.name == '') {
      throw ArgumentError.value(request.name, 'name', 'must not be empty');
    }
    final url = Uri.parse('/v1alpha1/${request.name}:wait');
    final req = http.Request('POST', url)
      ..headers['content-type'] = 'application/json'
      ..headers['accept'] = 'application/json'
      ..body = jsonEncode(
        request.toProto3Json(
          typeRegistry: CelestCloud.typeRegistry,
        ),
      );
    final res = await _client.send(req);
    final body = await res.stream.toBytes();
    if (res.statusCode != 200) {
      throwError(
        statusCode: res.statusCode,
        bodyBytes: body,
      );
    }
    return Operation()
      ..mergeFromProto3Json(
        JsonUtf8.decode(body),
        typeRegistry: CelestCloud.typeRegistry,
      );
  }
}