defmodule Ada.V1.IngestMode do
  @moduledoc false

  use Protobuf,
    enum: true,
    full_name: "ada.v1.IngestMode",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:INGEST_MODE_UNSPECIFIED, 0)
  field(:INGEST_MODE_DOCUMENT, 1)
end

defmodule Ada.V1.DocumentStatus do
  @moduledoc false

  use Protobuf,
    enum: true,
    full_name: "ada.v1.DocumentStatus",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:DOCUMENT_STATUS_UNSPECIFIED, 0)
  field(:DOCUMENT_STATUS_PENDING, 1)
  field(:DOCUMENT_STATUS_PROCESSING, 2)
  field(:DOCUMENT_STATUS_COMPLETED, 3)
  field(:DOCUMENT_STATUS_FAILED, 4)
end

defmodule Ada.V1.IngestJobStatus do
  @moduledoc false

  use Protobuf,
    enum: true,
    full_name: "ada.v1.IngestJobStatus",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:INGEST_JOB_STATUS_UNSPECIFIED, 0)
  field(:INGEST_JOB_STATUS_PENDING, 1)
  field(:INGEST_JOB_STATUS_RUNNING, 2)
  field(:INGEST_JOB_STATUS_COMPLETED, 3)
  field(:INGEST_JOB_STATUS_FAILED, 4)
  field(:INGEST_JOB_STATUS_CANCELED, 5)
  field(:INGEST_JOB_STATUS_RETRYING, 6)
end

defmodule Ada.V1.IngestJobStage do
  @moduledoc false

  use Protobuf,
    enum: true,
    full_name: "ada.v1.IngestJobStage",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:INGEST_JOB_STAGE_UNSPECIFIED, 0)
  field(:INGEST_JOB_STAGE_DOCUMENT_REGISTRATION, 1)
  field(:INGEST_JOB_STAGE_CONTENT_EXTRACTION, 2)
  field(:INGEST_JOB_STAGE_CHUNKING, 3)
  field(:INGEST_JOB_STAGE_EMBEDDING, 4)
  field(:INGEST_JOB_STAGE_ENTITY_EXTRACTION, 5)
  field(:INGEST_JOB_STAGE_RELATION_EXTRACTION, 6)
  field(:INGEST_JOB_STAGE_ATOM_EXTRACTION, 7)
  field(:INGEST_JOB_STAGE_DEDUPLICATION, 8)
  field(:INGEST_JOB_STAGE_CONFLICT_RESOLUTION, 9)
  field(:INGEST_JOB_STAGE_GRAPH_PERSISTENCE, 10)
  field(:INGEST_JOB_STAGE_VECTOR_PERSISTENCE, 11)
  field(:INGEST_JOB_STAGE_COMMUNITY_DETECTION, 12)
  field(:INGEST_JOB_STAGE_TEMPORAL_GRAPH, 13)
  field(:INGEST_JOB_STAGE_COMPLETION, 14)
  field(:INGEST_JOB_STAGE_DISTILLING, 15)
  field(:INGEST_JOB_STAGE_RECALLING, 16)
  field(:INGEST_JOB_STAGE_RETRYING, 17)
end

defmodule Ada.V1.IngestAccountingStatus do
  @moduledoc false

  use Protobuf,
    enum: true,
    full_name: "ada.v1.IngestAccountingStatus",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:INGEST_ACCOUNTING_STATUS_UNSPECIFIED, 0)
  field(:INGEST_ACCOUNTING_STATUS_PENDING, 1)
  field(:INGEST_ACCOUNTING_STATUS_COMPUTED, 2)
  field(:INGEST_ACCOUNTING_STATUS_FAILED, 3)
end

defmodule Ada.V1.AccountingContext do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.AccountingContext",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:organization_id, 1, type: :string, json_name: "organizationId")
  field(:project_id, 2, type: :string, json_name: "projectId")
  field(:principal_id, 3, type: :string, json_name: "principalId")
  field(:invocation_id, 4, type: :string, json_name: "invocationId")
  field(:run_id, 5, type: :string, json_name: "runId")
  field(:tool_invocation_id, 6, type: :string, json_name: "toolInvocationId")
  field(:tool_attempt_id, 7, type: :string, json_name: "toolAttemptId")
  field(:application_name, 8, type: :string, json_name: "applicationName")
  field(:resource_name, 9, type: :string, json_name: "resourceName")
  field(:tool_name, 10, type: :string, json_name: "toolName")
  field(:source_id, 11, type: :string, json_name: "sourceId")
end

defmodule Ada.V1.DocumentPayload do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.DocumentPayload",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:title, 1, type: :string)
  field(:text, 2, type: :string)
end

defmodule Ada.V1.GetDocumentStatusRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetDocumentStatusRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:document_id, 1, type: :string, json_name: "documentId")
  field(:source_id, 2, type: :string, json_name: "sourceId")
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.GetDocumentStatusResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetDocumentStatusResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:found, 1, type: :bool)
  field(:document_id, 2, type: :string, json_name: "documentId")
  field(:source_id, 3, type: :string, json_name: "sourceId")
  field(:status, 4, type: Ada.V1.DocumentStatus, enum: true)
  field(:version, 5, type: :int32)
  field(:size_bytes, 6, type: :int64, json_name: "sizeBytes")
  field(:chunk_count, 7, type: :int32, json_name: "chunkCount")
  field(:created_at, 8, type: Google.Protobuf.Timestamp, json_name: "createdAt")
  field(:updated_at, 9, type: Google.Protobuf.Timestamp, json_name: "updatedAt")
  field(:name, 10, type: :string)
  field(:mime_type, 11, type: :string, json_name: "mimeType")
end

defmodule Ada.V1.GetJobStatusRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetJobStatusRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:job_id, 1, type: :string, json_name: "jobId")
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.GetJobStatusResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetJobStatusResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:found, 1, type: :bool)
  field(:job, 2, type: Ada.V1.JobStatus)
end

defmodule Ada.V1.GetIngestAccountingRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetIngestAccountingRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:job_id, 1, type: :string, json_name: "jobId")
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.IngestAccounting do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.IngestAccounting",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:job_id, 1, type: :string, json_name: "jobId")
  field(:document_id, 2, type: :string, json_name: "documentId")
  field(:status, 3, type: Ada.V1.IngestAccountingStatus, enum: true)
  field(:accounting_version, 4, type: :int32, json_name: "accountingVersion")
  field(:document_size_bytes, 5, type: :int64, json_name: "documentSizeBytes")
  field(:chunk_count, 6, type: :int64, json_name: "chunkCount")
  field(:postgres_bytes, 7, type: :int64, json_name: "postgresBytes")
  field(:postgres_row_count, 8, type: :int64, json_name: "postgresRowCount")
  field(:qdrant_estimated_bytes, 9, type: :int64, json_name: "qdrantEstimatedBytes")
  field(:qdrant_point_count, 10, type: :int64, json_name: "qdrantPointCount")
  field(:qdrant_vector_dimensions, 11, type: :int32, json_name: "qdrantVectorDimensions")
  field(:neo4j_estimated_bytes, 12, type: :int64, json_name: "neo4jEstimatedBytes")
  field(:neo4j_statement_count, 13, type: :int64, json_name: "neo4jStatementCount")
  field(:object_store_bytes, 14, type: :int64, json_name: "objectStoreBytes")
  field(:total_estimated_bytes, 15, type: :int64, json_name: "totalEstimatedBytes")
  field(:details, 16, type: Google.Protobuf.Struct)
  field(:error, 17, type: :string)
  field(:computed_at, 18, type: Google.Protobuf.Timestamp, json_name: "computedAt")
  field(:created_at, 19, type: Google.Protobuf.Timestamp, json_name: "createdAt")
  field(:updated_at, 20, type: Google.Protobuf.Timestamp, json_name: "updatedAt")
end

defmodule Ada.V1.GetIngestAccountingResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetIngestAccountingResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:found, 1, type: :bool)
  field(:accounting, 2, type: Ada.V1.IngestAccounting)
end

defmodule Ada.V1.GetLatestJobByDocumentRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetLatestJobByDocumentRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:document_id, 1, type: :string, json_name: "documentId")
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.IngestAcceptedResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.IngestAcceptedResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:mode, 1, type: Ada.V1.IngestMode, enum: true)
  field(:document_id, 2, type: :string, json_name: "documentId")
  field(:extraction_model, 3, type: :string, json_name: "extractionModel")
  field(:job_id, 4, type: :string, json_name: "jobId")
  field(:job_status, 5, type: Ada.V1.IngestJobStatus, json_name: "jobStatus", enum: true)
end

defmodule Ada.V1.IngestRequest.MetadataEntry do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.IngestRequest.MetadataEntry",
    map: true,
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:key, 1, type: :string)
  field(:value, 2, type: :string)
end

defmodule Ada.V1.IngestRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.IngestRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:mode, 1, type: Ada.V1.IngestMode, enum: true)
  field(:document, 4, type: Ada.V1.DocumentPayload)
  field(:source, 5, type: Ada.V1.SourcePayload)
  field(:metadata, 6, repeated: true, type: Ada.V1.IngestRequest.MetadataEntry, map: true)
  field(:include_details, 7, proto3_optional: true, type: :bool, json_name: "includeDetails")

  field(:reference_time_utc, 8,
    proto3_optional: true,
    type: Google.Protobuf.Timestamp,
    json_name: "referenceTimeUtc"
  )

  field(:extraction_model, 9, proto3_optional: true, type: :string, json_name: "extractionModel")
  field(:distill_model, 10, proto3_optional: true, type: :string, json_name: "distillModel")
  field(:available_tokens, 12, type: :int64, json_name: "availableTokens")
  field(:accounting_context, 13, type: Ada.V1.AccountingContext, json_name: "accountingContext")
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.EstimateIngestRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.EstimateIngestRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:text, 1, type: :string)
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.EstimateIngestResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.EstimateIngestResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:estimated_tokens, 1, type: :int64, json_name: "estimatedTokens")
  field(:sufficient, 2, type: :bool)
  field(:available_tokens, 3, type: :int64, json_name: "availableTokens")
end

defmodule Ada.V1.JobProgress do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.JobProgress",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:stage, 1, type: Ada.V1.IngestJobStage, enum: true)
  field(:percentage, 2, type: :int32)
  field(:overall_percentage, 3, type: :int32, json_name: "overallPercentage")
  field(:message, 4, type: :string)
end

defmodule Ada.V1.JobStatus do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.JobStatus",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:id, 1, type: :string)
  field(:document_id, 2, type: :string, json_name: "documentId")
  field(:source_id, 3, type: :string, json_name: "sourceId")
  field(:content_type, 4, type: :string, json_name: "contentType")
  field(:status, 5, type: Ada.V1.IngestJobStatus, enum: true)
  field(:progress, 6, type: Ada.V1.JobProgress)
  field(:error, 7, type: :string)
  field(:retry_count, 8, type: :int32, json_name: "retryCount")
  field(:max_retries, 9, type: :int32, json_name: "maxRetries")
  field(:partial_failure, 10, type: :bool, json_name: "partialFailure")

  field(:partial_failure_causes, 11,
    repeated: true,
    type: :string,
    json_name: "partialFailureCauses"
  )

  field(:extraction_model, 12, type: :string, json_name: "extractionModel")
  field(:created_at, 13, type: Google.Protobuf.Timestamp, json_name: "createdAt")
  field(:updated_at, 14, type: Google.Protobuf.Timestamp, json_name: "updatedAt")
  field(:started_at, 15, type: Google.Protobuf.Timestamp, json_name: "startedAt")
  field(:completed_at, 16, type: Google.Protobuf.Timestamp, json_name: "completedAt")
  field(:llm_call_count, 17, type: :int64, json_name: "llmCallCount")
  field(:llm_input_tokens, 18, type: :int64, json_name: "llmInputTokens")
  field(:llm_output_tokens, 19, type: :int64, json_name: "llmOutputTokens")
  field(:llm_total_tokens, 20, type: :int64, json_name: "llmTotalTokens")
  field(:accounting_context, 24, type: Ada.V1.AccountingContext, json_name: "accountingContext")
end

defmodule Ada.V1.JobStarted do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.JobStarted",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:job, 1, type: Ada.V1.JobStatus)
end

defmodule Ada.V1.JobProgressed do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.JobProgressed",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:job, 1, type: Ada.V1.JobStatus)
end

defmodule Ada.V1.JobFinished do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.JobFinished",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:job, 1, type: Ada.V1.JobStatus)
end

defmodule Ada.V1.JobStatusStreamEvent do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.JobStatusStreamEvent",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  oneof(:event, 0)

  field(:job_id, 3, type: :string, json_name: "jobId")
  field(:timestamp, 4, type: Google.Protobuf.Timestamp)
  field(:event_id, 6, type: :string, json_name: "eventId")
  field(:principal_id, 100, type: :string, json_name: "principalId")
  field(:started, 20, type: Ada.V1.JobStarted, oneof: 0)
  field(:progressed, 21, type: Ada.V1.JobProgressed, oneof: 0)
  field(:finished, 22, type: Ada.V1.JobFinished, oneof: 0)
end

defmodule Ada.V1.SourcePayload do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.SourcePayload",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:type, 1, type: :string)
  field(:id, 2, type: :string)
end

defmodule Ada.V1.StreamJobsRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.StreamJobsRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:after_event_id, 1, type: :string, json_name: "afterEventId")
  field(:replay_limit, 2, type: :int32, json_name: "replayLimit")
  field(:principal_id, 100, type: :string, json_name: "principalId")
  field(:scope_mode, 101, type: Ada.V1.StreamScopeMode, json_name: "scopeMode", enum: true)
end

defmodule Ada.V1.SetMeEntityRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.SetMeEntityRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:entity_id, 1, type: :string, json_name: "entityId")
  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.SetMeEntityResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.SetMeEntityResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:ok, 1, type: :bool)
  field(:entity_id, 2, type: :string, json_name: "entityId")
end

defmodule Ada.V1.GetMeEntityRequest do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetMeEntityRequest",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:principal_id, 100, type: :string, json_name: "principalId")
end

defmodule Ada.V1.GetMeEntityResponse do
  @moduledoc false

  use Protobuf,
    full_name: "ada.v1.GetMeEntityResponse",
    protoc_gen_elixir_version: "0.17.0",
    syntax: :proto3

  field(:found, 1, type: :bool)
  field(:entity_id, 2, type: :string, json_name: "entityId")
end

defmodule Ada.V1.IngestService.Service do
  @moduledoc false

  use GRPC.Service, name: "ada.v1.IngestService", protoc_gen_elixir_version: "0.17.0"

  rpc(:GetDocumentStatus, Ada.V1.GetDocumentStatusRequest, Ada.V1.GetDocumentStatusResponse)

  rpc(:GetJobStatus, Ada.V1.GetJobStatusRequest, Ada.V1.GetJobStatusResponse)

  rpc(:GetIngestAccounting, Ada.V1.GetIngestAccountingRequest, Ada.V1.GetIngestAccountingResponse)

  rpc(:GetLatestJobByDocument, Ada.V1.GetLatestJobByDocumentRequest, Ada.V1.GetJobStatusResponse)

  rpc(:EstimateIngest, Ada.V1.EstimateIngestRequest, Ada.V1.EstimateIngestResponse)

  rpc(:Ingest, Ada.V1.IngestRequest, Ada.V1.IngestAcceptedResponse)

  rpc(:StreamJobs, Ada.V1.StreamJobsRequest, stream(Ada.V1.JobStatusStreamEvent))

  rpc(:SetMeEntity, Ada.V1.SetMeEntityRequest, Ada.V1.SetMeEntityResponse)

  rpc(:GetMeEntity, Ada.V1.GetMeEntityRequest, Ada.V1.GetMeEntityResponse)
end

defmodule Ada.V1.IngestService.Stub do
  @moduledoc false

  use GRPC.Stub, service: Ada.V1.IngestService.Service
end