Function create_subscription 

pub async fn create_subscription(
    state: &AppState,
    identity: IdentityId,
    query: &str,
) -> Result<SubscriptionId, CreateSubscriptionError>

Execute CREATE SUBSCRIPTION AS { query } and extract the subscription ID from the result.