CRUD endpoints for services

DSL/Liquibase/changelog/rag-search-script-v6-services.sql

@@ -0,0 +1,37 @@
+-- changeset Erangi Ariyasena:rag-script-v6-changeset1
+
+-- Custom types used:
+CREATE TYPE ruuter_request_type AS ENUM ('GET', 'POST');
+CREATE TYPE service_state AS ENUM ('active', 'inactive', 'draft');
+
+CREATE TABLE public.services (
+  -- Primary key
+  id SERIAL PRIMARY KEY,
+
+  -- Basic service information
+  name TEXT NOT NULL,
+  description TEXT NOT NULL,
+  service_id TEXT NOT NULL UNIQUE, 
+
+  -- Service classification
+  ruuter_type ruuter_request_type DEFAULT 'GET',  -- ENUM: 'GET' or 'POST'
+  current_state service_state DEFAULT 'draft',    -- ENUM: 'active', 'inactive', 'draft'
+  is_common BOOLEAN NOT NULL DEFAULT FALSE,
+
+  -- Intent classification data (for LLM)
+  slot TEXT NOT NULL DEFAULT '',
+  entities text[] NOT NULL DEFAULT '{}',
+  examples text[] NOT NULL DEFAULT '{}',
+
+  -- Service configuration
+  structure JSON NOT NULL DEFAULT '{}',
+  endpoints JSON NOT NULL DEFAULT '[]',
+
+  -- Timestamps
+  created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,
+  updated_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Create index for unique service_id for faster lookups
+CREATE UNIQUE INDEX idx_services_service_id ON public.services(service_id);
+

DSL/Liquibase/master.yml

@@ -8,4 +8,6 @@ databaseChangeLog:
   - include:
       file: changelog/rag-search-script-v4-authority-data.xml
   - include:
-      file: changelog/rag-search-script-v5-prompt-config.sql
+      file: changelog/rag-search-script-v6-services.sql
+  - include:
+      file: changelog/rag-search-script-v5-prompt-config.sql

DSL/Resql/rag-search/POST/delete-service.sql

@@ -0,0 +1,2 @@
+DELETE FROM services
+WHERE id = :id;

DSL/Resql/rag-search/POST/get-service.sql

@@ -0,0 +1,17 @@
+SELECT 
+    id,
+    name,
+    description,
+    service_id,
+    ruuter_type,
+    current_state,
+    is_common,
+    slot,
+    entities,
+    examples,
+    structure,
+    endpoints,
+    created_at,
+    updated_at
+FROM services
+WHERE id = :id;

DSL/Resql/rag-search/POST/insert-service.sql

@@ -0,0 +1,43 @@
+INSERT INTO services (
+    name,
+    description,
+    service_id,
+    ruuter_type,
+    current_state,
+    is_common,
+    slot,
+    entities,
+    examples,
+    structure,
+    endpoints,
+    created_at,
+    updated_at
+) VALUES (
+    :name,
+    :description,
+    :service_id,
+    :ruuter_type::ruuter_request_type,
+    :current_state::service_state,
+    :is_common,
+    :slot,
+    ARRAY[:entities]::text[],
+    ARRAY[:examples]::text[],
+    :structure::json,
+    :endpoints::json,
+    :created_at::timestamp with time zone,
+    :updated_at::timestamp with time zone
+) RETURNING 
+    id,
+    name,
+    description,
+    service_id,
+    ruuter_type,
+    current_state,
+    is_common,
+    slot,
+    entities,
+    examples,
+    structure,
+    endpoints,
+    created_at,
+    updated_at;

DSL/Resql/rag-search/POST/update-service.sql

@@ -0,0 +1,30 @@
+UPDATE services 
+SET 
+    name = :name,
+    description = :description,
+    service_id = :service_id,
+    ruuter_type = :ruuter_type::ruuter_request_type,
+    current_state = :current_state::service_state,
+    is_common = :is_common,
+    slot = :slot,
+    entities = ARRAY[:entities]::text[],
+    examples = ARRAY[:examples]::text[],
+    structure = :structure::json,
+    endpoints = :endpoints::json,
+    updated_at = :updated_at::timestamp with time zone
+WHERE id = :id
+RETURNING
+    id,
+    name,
+    description,
+    service_id,
+    ruuter_type,
+    current_state,
+    is_common,
+    slot,
+    entities,
+    examples,
+    structure,
+    endpoints,
+    created_at,
+    updated_at;

DSL/Ruuter.private/rag-search/POST/services/add.yml

@@ -0,0 +1,107 @@
+declaration:
+  call: declare
+  version: 0.1
+  description: "Add a new service"
+  method: post
+  accepts: json
+  returns: json
+  namespace: rag-search
+  allowlist:
+    body:
+      - field: name
+        type: string
+        description: "Service name"
+      - field: description
+        type: string
+        description: "Service description"
+      - field: service_id
+        type: string
+        description: "Unique service identifier"
+      - field: ruuter_type
+        type: string
+        description: "Ruuter request type (GET or POST)"
+      - field: current_state
+        type: string
+        description: "Service state (active, inactive, draft)"
+      - field: is_common
+        type: boolean
+        description: "Whether the service is common"
+      - field: slot
+        type: string
+        description: "Intent classification slot"
+      - field: entities
+        type: array
+        description: "Array of entities for intent classification"
+      - field: examples
+        type: array
+        description: "Array of example phrases for intent classification"
+      - field: structure
+        type: object
+        description: "Service configuration structure"
+      - field: endpoints
+        type: array
+        description: "Array of service endpoints"
+
+extract_request_data:
+  assign:
+    name: ${incoming.body.name}
+    description: ${incoming.body.description}
+    service_id: ${incoming.body.service_id}
+    ruuter_type: ${incoming.body.ruuter_type || "GET"}
+    current_state: ${incoming.body.current_state || "draft"}
+    is_common: ${incoming.body.is_common || false}
+    slot: ${incoming.body.slot || ""}
+    entities: ${incoming.body.entities}
+    examples: ${incoming.body.examples}
+    structure: ${JSON.stringify(incoming.body.structure)}
+    endpoints: ${JSON.stringify(incoming.body.endpoints)}
+    created_at: ${new Date().toISOString()}
+    updated_at: ${new Date().toISOString()}
+  next: validate_required_fields
+
+validate_required_fields:
+  switch:
+    - condition: "${!name || !description || !service_id}"
+      next: return_validation_error
+  next: insert_service
+
+insert_service:
+  call: http.post
+  args:
+    url: "[#RAG_SEARCH_RESQL]/insert-service"
+    body:
+      name: ${name}
+      description: ${description}
+      service_id: ${service_id}
+      ruuter_type: ${ruuter_type}
+      current_state: ${current_state}
+      is_common: ${is_common}
+      slot: ${slot}
+      entities: ${entities}
+      examples: ${examples}
+      structure: ${structure}
+      endpoints: ${endpoints}
+      created_at: ${created_at}
+      updated_at: ${updated_at}
+  result: insert_result
+  next: handle_insert_response
+
+handle_insert_response:
+  switch:
+    - condition: "${insert_result.response.statusCodeValue >= 400}"
+      next: return_error
+  next: return_success
+
+return_success:
+  return: "Service created successfully"
+  next: end
+
+return_validation_error:
+  status: 400
+  return: "Missing required fields: name, description, and service_id are required"
+  next: end
+
+return_error:
+  status: 500
+  return: "Failed to create service"
+  next: end

DSL/Ruuter.private/rag-search/POST/services/delete.yml

@@ -0,0 +1,74 @@
+declaration:
+  call: declare
+  version: 0.1
+  description: "Delete a service (soft delete)"
+  method: post
+  accepts: json
+  returns: json
+  namespace: rag-search
+  allowlist:
+    body:
+      - field: id
+        type: number
+        description: "Service ID"
+
+extract_request_data:
+  assign:
+    id: ${Number(incoming.body.id)}
+    updated_at: ${new Date().toISOString()}
+  next: validate_id
+
+validate_id:
+  switch:
+    - condition: "${!id}"
+      next: return_validation_error
+  next: check_service_exists
+
+check_service_exists:
+  call: http.post
+  args:
+    url: "[#RAG_SEARCH_RESQL]/get-service"
+    body:
+      id: ${id}
+  result: existing_service
+  next: validate_service_exists
+
+validate_service_exists:
+  switch:
+    - condition: "${existing_service.response.body.length > 0}"
+      next: delete_service
+  next: return_not_found
+
+delete_service:
+  call: http.post
+  args:
+    url: "[#RAG_SEARCH_RESQL]/delete-service"
+    body:
+      id: ${id}
+  result: delete_result
+  next: handle_delete_response
+
+handle_delete_response:
+  switch:
+    - condition: "${delete_result.response.statusCodeValue >= 400}"
+      next: return_error
+  next: return_success
+
+return_success:
+  return: "Service deleted successfully"
+  next: end
+
+return_validation_error:
+  status: 400
+  return: "Missing required field: id is required"
+  next: end
+
+return_not_found:
+  status: 404
+  return: "Service not found"
+  next: end
+
+return_error:
+  status: 500
+  return: "Failed to delete service"
+  next: end