handleCustomRequest method

@override Future<JSAny?> handleCustomRequest(ClientConnection connection, JSAny? request)

Handles a custom request (encoded as any JS value) from the connection.

The response is sent over the channel and completes a Database.customRequest call for clients.

Implementation

@override
Future<JSAny?> handleCustomRequest(
    ClientConnection connection, JSAny? request) async {
  final message = request as CustomDatabaseMessage;

  switch (message.kind) {
    case CustomDatabaseMessageKind.requestSharedLock:
      await mutex.acquireRead();
    case CustomDatabaseMessageKind.requestExclusiveLock:
      await mutex.acquireWrite();
    case CustomDatabaseMessageKind.releaseLock:
      mutex.release();
    case CustomDatabaseMessageKind.lockObtained:
      throw UnsupportedError('This is a response, not a request');
    case CustomDatabaseMessageKind.getAutoCommit:
      return database.autocommit.toJS;
    case CustomDatabaseMessageKind.executeInTransaction:
      final sql = message.rawSql.toDart;
      final hasTypeInfo = message.typeInfo.isDefinedAndNotNull;
      final parameters = proto.deserializeParameters(
          message.rawParameters, message.typeInfo);
      if (database.autocommit) {
        throw SqliteException(0,
            "Transaction rolled back by earlier statement. Cannot execute: $sql");
      }

      var res = database.select(sql, parameters);
      if (hasTypeInfo) {
        // If the client is sending a request that has parameters with type
        // information, it will also support a newer serialization format for
        // result sets.
        return JSObject()
          ..['format'] = 2.toJS
          ..['r'] = proto.serializeResultSet(res);
      } else {
        var dartMap = resultSetToMap(res);
        var jsObject = dartMap.jsify();
        return jsObject;
      }

    case CustomDatabaseMessageKind.executeBatchInTransaction:
      final sql = message.rawSql.toDart;
      final parameters = proto.deserializeParameters(
          message.rawParameters, message.typeInfo);
      if (database.autocommit) {
        throw SqliteException(0,
            "Transaction rolled back by earlier statement. Cannot execute: $sql");
      }
      database.execute(sql, parameters);
  }

  return CustomDatabaseMessage(CustomDatabaseMessageKind.lockObtained);
}