Queries

query GetAsset($id: UUID!) {
  asset(id: $id) {
    id
    name
    assetType
    externalId
    attributes
    geometry {
      type
      coordinates
    }
    createdAt
    updatedAt
  }
}

{
  "id": "550e8400-e29b-41d4-a716-446655440000"
}

query SearchAssets(
  $assetType: AssetType
  $nameContains: String
  $hasRecentEvents: Boolean
  $limit: Int
) {
  searchAssets(
    assetType: $assetType
    nameContains: $nameContains
    hasRecentEvents: $hasRecentEvents
    limit: $limit
  ) {
    id
    name
    assetType
    externalId
    geometry {
      type
      coordinates
    }
  }
}

{
  "assetType": "RECTIFIER",
  "nameContains": "North",
  "limit": 10
}

query GetAssetStatus($id: UUID!) {
  assetStatus(id: $id) {
    asset {
      id
      name
      assetType
    }
    recentMeasurements {
      measurementType
      value
      unit
      recordedAt
    }
    recentEvents {
      id
      eventType
      severity
      title
      occurredAt
    }
    riskScore
    complianceStatus
  }
}

query PipelineSummary {
  pipelineSummary {
    totalAssets
    totalPipelines
    totalSegments
    totalTestStations
    totalRectifiers
    assetsByType {
      assetType
      count
    }
    recentEvents {
      id
      title
      severity
      occurredAt
    }
    measurementStats {
      measurementType
      avgValue
      minValue
      maxValue
      count
    }
  }
}

query ListPipelines {
  pipelines {
    id
    name
    operator
    productType
    segments {
      id
      name
      startMilePost
      endMilePost
      diameterInches
    }
  }
}

query QueryMeasurements(
  $assetId: UUID!
  $measurementType: String
  $startTime: DateTime
  $endTime: DateTime
  $limit: Int
) {
  measurements(
    assetId: $assetId
    measurementType: $measurementType
    startTime: $startTime
    endTime: $endTime
    limit: $limit
  ) {
    id
    measurementType
    value
    unit
    recordedAt
    recordedBy
    source
    quality
  }
}

{
  "assetId": "550e8400-e29b-41d4-a716-446655440000",
  "measurementType": "pipe_to_soil_potential",
  "startTime": "2024-12-01T00:00:00Z",
  "endTime": "2024-12-08T00:00:00Z",
  "limit": 100
}

query MeasurementTrends(
  $assetId: UUID!
  $measurementType: String!
  $interval: String!
  $startTime: DateTime!
  $endTime: DateTime!
) {
  measurementTrends(
    assetId: $assetId
    measurementType: $measurementType
    interval: $interval
    startTime: $startTime
    endTime: $endTime
  ) {
    timestamp
    avgValue
    minValue
    maxValue
    count
  }
}

query FindProtectionSystems($assetId: UUID!) {
  protectionSystems(assetId: $assetId) {
    rectifiers {
      id
      name
      currentOutput
      voltageOutput
      status
    }
    testStations {
      id
      name
      lastReading {
        value
        recordedAt
      }
    }
    anodeBeds {
      id
      name
      anodeCount
      installDate
    }
  }
}

query AnalyzeImpact($assetId: UUID!, $failureType: FailureType) {
  impactAnalysis(assetId: $assetId, failureType: $failureType) {
    affectedAssets {
      id
      name
      assetType
      impactLevel
    }
    totalAffectedSegments
    totalAffectedMiles
    estimatedRepairTime
    recommendations
  }
}

query RelationshipGraph($assetId: UUID!, $depth: Int) {
  relationshipGraph(assetId: $assetId, depth: $depth) {
    nodes {
      id
      name
      assetType
      riskScore
    }
    edges {
      source
      target
      relationshipType
    }
  }
}

query ComplianceStatus($regulation: String) {
  complianceStatus(regulation: $regulation) {
    regulation
    status
    dueItems
    overdueItems
    upcomingDeadlines {
      assetId
      assetName
      deadline
      requirement
    }
  }
}

query PaginatedAssets($first: Int, $after: String) {
  assets(first: $first, after: $after) {
    edges {
      node {
        id
        name
      }
      cursor
    }
    pageInfo {
      hasNextPage
      endCursor
    }
  }
}