feat: Implement pagination for airline listing by country

Author: teetangh

app/controllers/api/v1/airlines_controller.rb

@@ -77,13 +77,14 @@ def destroy
       # GET /api/v1/airlines/list
       def index
         country = params[:country]
-        offset = params[:offset].to_i || 0
-        limit = params[:limit].to_i || 10
+        limit = params[:limit] || 10
+        offset = params[:offset] || 0
 
         begin
           airlines = if country.present?
-                       Airline.list_by_country(key: [country])
+                       Airline.list_by_country(key: [country, limit, offset])
                      else
+                       # TODO: Implement pagination
                        Airline.all
                      end
 
@@ -111,10 +112,11 @@ def to_airport
         raise ArgumentError, 'Destination airport is missing' unless params[:destinationAirportCode].present?
 
         destination_airport = params[:destinationAirportCode]
-        offset = params[:offset].to_i || 0
-        limit = params[:limit].to_i || 10
+        limit = params[:limit] || 10
+        offset = params[:offset] || 0
 
-        airlines = Airline.to_airport(key: [destination_airport])
+        puts "Destination airport: #{destination_airport}, limit: #{limit}, offset: #{offset}"
+        airlines = Airline.to_airport(key: [destination_airport, limit, offset])
                           .pluck(:callsign, :country, :iata, :icao, :name)
 
         formatted_airlines = airlines.map do |airline|

app/models/airline.rb

@@ -18,13 +18,11 @@ class Airline < CouchbaseOrm::Base
   validates :country, presence: true
 
   # Custom N1QL query to list airlines by country with pagination
-  n1ql :list_by_country, emit_key: [:country], query_fn: proc { |bucket, values, options|
-    cluster.query("SELECT raw meta().id FROM `#{bucket.name}` WHERE type = 'airline' AND country = #{quote(values[0])} LIMIT 10 OFFSET 0", options)
+  n1ql :list_by_country, query_fn: proc { |bucket, values, options|
+    cluster.query("SELECT raw meta().id FROM `#{bucket.name}` WHERE type = 'airline' AND country = #{quote(values[0])} LIMIT #{values[1]} OFFSET #{values[2]}", options)
   }
 
   n1ql :to_airport, query_fn: proc { |bucket, values, options|
-                                # limit = options[:limit] || 10
-                                # offset = options[:offset] || 0
-                                cluster.query("SELECT raw META(air).id FROM (SELECT DISTINCT META(airline).id AS airlineId FROM `#{bucket.name}` AS route JOIN `#{bucket.name}` AS airline ON route.airlineid = META(airline).id WHERE route.destinationairport = #{quote(values[0])}) AS subquery JOIN `#{bucket.name}` AS air ON META(air).id = subquery.airlineId LIMIT 10 OFFSET 0", options)
-                              }
+    cluster.query("SELECT raw META(air).id FROM (SELECT DISTINCT META(airline).id AS airlineId FROM `#{bucket.name}` AS route JOIN `#{bucket.name}` AS airline ON route.airlineid = META(airline).id WHERE route.destinationairport = #{quote(values[0])}) AS subquery JOIN `#{bucket.name}` AS air ON META(air).id = subquery.airlineId LIMIT #{values[1]} OFFSET #{values[2]}", options)
+  }
 end