AzureDataTransfer_listApprovedSchemas

enum_listApprovedSchemasRequestDirection := [ "Send", "Receive" ]

valid {
    input.Body.pipeline == STRING
    input.Body.direction == enum_listApprovedSchemasRequestDirection[_]
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
}

AzureDataTransfer_validateSchema

enum_schemaStatus := [ "New", "Approved" ]

valid {
    input.Body.id == STRING
    input.Body.connectionId == STRING
    input.Body.status == enum_schemaStatus[_]
    input.Body.name == STRING
    input.Body.content == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
}

Connections_CreateOrUpdate

enum_connectionPropertiesDirection := [ "Send", "Receive" ]
enum_flowType := [ "Unknown", "Complex", "DevSecOps", "Messaging", "Mission", "MicrosoftInternal", "BasicFiles", "Data" ]
enum_schemaStatus := [ "New", "Approved" ]

valid {
    input.Body.properties.pipeline == STRING
    input.Body.properties.direction == enum_connectionPropertiesDirection[_]
    input.Body.properties.justification == STRING
    input.Body.properties.flowTypes[_] == enum_flowType[_]
    input.Body.properties.requirementId == STRING
    input.Body.properties.remoteSubscriptionId == STRING
    input.Body.properties.pin == STRING
    input.Body.properties.primaryContact == STRING
    input.Body.properties.secondaryContacts[_] == STRING
    input.Body.properties.policies[_] == STRING
    input.Body.properties.schemas[_].id == STRING
    input.Body.properties.schemas[_].connectionId == STRING
    input.Body.properties.schemas[_].status == enum_schemaStatus[_]
    input.Body.properties.schemas[_].name == STRING
    input.Body.properties.schemas[_].content == STRING
    input.Body.tags.STRING == STRING
    input.Body.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Connections_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Connections_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Connections_Link

valid {
    input.Body.id == STRING
    input.Body.statusReason == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Connections_ListByResourceGroup

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Connections_ListBySubscription

valid {
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Connections_Update

valid {
    input.Body.tags.STRING == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_CreateOrUpdate

enum_ManagedServiceIdentityType := [ "None", "SystemAssigned", "UserAssigned", "SystemAssigned,UserAssigned" ]
enum_flowPropertiesDataType := [ "Blob", "Table" ]
enum_flowPropertiesStatus := [ "Enabled", "Disabled" ]
enum_flowType := [ "Unknown", "Complex", "DevSecOps", "Messaging", "Mission", "MicrosoftInternal", "BasicFiles", "Data" ]
enum_messagingOptionsBillingTier := [ "BlobTransport", "Standard", "Premium" ]
enum_schemaStatus := [ "New", "Approved" ]

valid {
    input.Body.properties.connection.name == STRING
    input.Body.properties.connection.id == STRING
    input.Body.properties.connection.location == STRING
    input.Body.properties.connection.subscriptionName == STRING
    input.Body.properties.keyVaultUri == STRING
    input.Body.properties.status == enum_flowPropertiesStatus[_]
    input.Body.properties.storageAccountName == STRING
    input.Body.properties.storageAccountId == STRING
    input.Body.properties.storageContainerName == STRING
    input.Body.properties.serviceBusQueueId == STRING
    input.Body.properties.flowType == enum_flowType[_]
    input.Body.properties.dataType == enum_flowPropertiesDataType[_]
    input.Body.properties.policies[_] == STRING
    input.Body.properties.schema.id == STRING
    input.Body.properties.schema.connectionId == STRING
    input.Body.properties.schema.status == enum_schemaStatus[_]
    input.Body.properties.schema.name == STRING
    input.Body.properties.schema.content == STRING
    input.Body.properties.messagingOptions.billingTier == enum_messagingOptionsBillingTier[_]
    input.Body.plan.name == STRING
    input.Body.plan.publisher == STRING
    input.Body.plan.product == STRING
    input.Body.plan.promotionCode == STRING
    input.Body.plan.version == STRING
    input.Body.identity.type == enum_ManagedServiceIdentityType[_]
    input.Body.identity.userAssignedIdentities.STRING == {}
    input.Body.tags.STRING == STRING
    input.Body.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_Disable

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_Enable

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_Link

valid {
    input.Body.id == STRING
    input.Body.statusReason == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_ListByConnection

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Flows_Update

enum_ManagedServiceIdentityType := [ "None", "SystemAssigned", "UserAssigned", "SystemAssigned,UserAssigned" ]

valid {
    input.Body.identity.type == enum_ManagedServiceIdentityType[_]
    input.Body.identity.userAssignedIdentities.STRING == {}
    input.Body.tags.STRING == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.ReqMap.flowName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

ListPendingConnections_List

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

ListPendingFlows_List

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.connectionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

ListSchemas_List

enum_schemaStatus := [ "New", "Approved" ]

valid {
    input.Body.id == STRING
    input.Body.connectionId == STRING
    input.Body.status == enum_schemaStatus[_]
    input.Body.name == STRING
    input.Body.content == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Operations_List

valid {
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
}

Pipelines_ApproveConnection

valid {
    input.Body.id == STRING
    input.Body.statusReason == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Pipelines_CreateOrUpdate

enum_flowType := [ "Unknown", "Complex", "DevSecOps", "Messaging", "Mission", "MicrosoftInternal", "BasicFiles", "Data" ]

valid {
    input.Body.properties.remoteCloud == STRING
    input.Body.properties.displayName == STRING
    input.Body.properties.subscribers[_].email == STRING
    input.Body.properties.subscribers[_].notifications == INTEGER
    input.Body.properties.policies[_] == STRING
    input.Body.properties.flowTypes[_] == enum_flowType[_]
    input.Body.tags.STRING == STRING
    input.Body.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Pipelines_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Pipelines_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Pipelines_ListByResourceGroup

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Pipelines_ListBySubscription

valid {
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Pipelines_RejectConnection

valid {
    input.Body.id == STRING
    input.Body.statusReason == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Pipelines_Update

enum_flowType := [ "Unknown", "Complex", "DevSecOps", "Messaging", "Mission", "MicrosoftInternal", "BasicFiles", "Data" ]

valid {
    input.Body.properties.connections[_].id == STRING
    input.Body.properties.connections[_].properties.internalMetadata.operationStatus == {}
    input.Body.properties.flowTypes[_] == enum_flowType[_]
    input.Body.tags.STRING == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.pipelineName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}