validateIntegrity method

  1. @override
VerificationContext validateIntegrity(
  1. Insertable<StoredAction> instance, {
  2. bool isInserting = false,
})
override

Validates that the given entity can be inserted into this table, meaning that it respects all constraints (nullability, text length, etc.).

Implementation

@override
VerificationContext validateIntegrity(
  Insertable<StoredAction> instance, {
  bool isInserting = false,
}) {
  final context = VerificationContext();
  final data = instance.toColumns(true);
  if (data.containsKey('id')) {
    context.handle(_idMeta, id.isAcceptableOrUnknown(data['id']!, _idMeta));
  } else if (isInserting) {
    context.missing(_idMeta);
  }
  if (data.containsKey('account_key')) {
    context.handle(
      _accountKeyMeta,
      accountKey.isAcceptableOrUnknown(data['account_key']!, _accountKeyMeta),
    );
  } else if (isInserting) {
    context.missing(_accountKeyMeta);
  }
  if (data.containsKey('action_key')) {
    context.handle(
      _actionKeyMeta,
      actionKey.isAcceptableOrUnknown(data['action_key']!, _actionKeyMeta),
    );
  } else if (isInserting) {
    context.missing(_actionKeyMeta);
  }
  if (data.containsKey('version')) {
    context.handle(
      _versionMeta,
      version.isAcceptableOrUnknown(data['version']!, _versionMeta),
    );
  }
  if (data.containsKey('kind')) {
    context.handle(
      _kindMeta,
      kind.isAcceptableOrUnknown(data['kind']!, _kindMeta),
    );
  }
  if (data.containsKey('payload_json')) {
    context.handle(
      _payloadJsonMeta,
      payloadJson.isAcceptableOrUnknown(
        data['payload_json']!,
        _payloadJsonMeta,
      ),
    );
  } else if (isInserting) {
    context.missing(_payloadJsonMeta);
  }
  if (data.containsKey('status')) {
    context.handle(
      _statusMeta,
      status.isAcceptableOrUnknown(data['status']!, _statusMeta),
    );
  } else if (isInserting) {
    context.missing(_statusMeta);
  }
  if (data.containsKey('ordering_key')) {
    context.handle(
      _orderingKeyMeta,
      orderingKey.isAcceptableOrUnknown(
        data['ordering_key']!,
        _orderingKeyMeta,
      ),
    );
  }
  if (data.containsKey('row_table_id')) {
    context.handle(
      _rowTableIdMeta,
      rowTableId.isAcceptableOrUnknown(
        data['row_table_id']!,
        _rowTableIdMeta,
      ),
    );
  }
  if (data.containsKey('row_key')) {
    context.handle(
      _rowKeyMeta,
      rowKey.isAcceptableOrUnknown(data['row_key']!, _rowKeyMeta),
    );
  }
  if (data.containsKey('queue_position')) {
    context.handle(
      _queuePositionMeta,
      queuePosition.isAcceptableOrUnknown(
        data['queue_position']!,
        _queuePositionMeta,
      ),
    );
  }
  if (data.containsKey('attempt_count')) {
    context.handle(
      _attemptCountMeta,
      attemptCount.isAcceptableOrUnknown(
        data['attempt_count']!,
        _attemptCountMeta,
      ),
    );
  }
  if (data.containsKey('next_attempt_at')) {
    context.handle(
      _nextAttemptAtMeta,
      nextAttemptAt.isAcceptableOrUnknown(
        data['next_attempt_at']!,
        _nextAttemptAtMeta,
      ),
    );
  }
  if (data.containsKey('last_error')) {
    context.handle(
      _lastErrorMeta,
      lastError.isAcceptableOrUnknown(data['last_error']!, _lastErrorMeta),
    );
  }
  if (data.containsKey('created_at')) {
    context.handle(
      _createdAtMeta,
      createdAt.isAcceptableOrUnknown(data['created_at']!, _createdAtMeta),
    );
  } else if (isInserting) {
    context.missing(_createdAtMeta);
  }
  if (data.containsKey('updated_at')) {
    context.handle(
      _updatedAtMeta,
      updatedAt.isAcceptableOrUnknown(data['updated_at']!, _updatedAtMeta),
    );
  } else if (isInserting) {
    context.missing(_updatedAtMeta);
  }
  return context;
}