feat: Update Airline controller to use offset and limit parameters

Author: teetangh

app/controllers/api/v1/airlines_controller.rb

@@ -77,9 +77,8 @@ def destroy
       # GET /api/v1/airlines/list
       def index
         country = params[:country]
-        page = params[:page].to_i || 1
-        per_page = params[:per_page].to_i || 10
-        offset = (page - 1) * per_page
+        offset = params[:offset].to_i || 0
+        limit = params[:limit].to_i || 10
 
         begin
           airlines = if country.present?
@@ -112,22 +111,11 @@ def to_airport
         raise ArgumentError, 'Destination airport is missing' unless params[:destinationAirportCode].present?
 
         destination_airport = params[:destinationAirportCode]
-        page = params[:page].to_i || 1
-        per_page = params[:per_page].to_i || 10
+        offset = params[:offset].to_i || 0
+        limit = params[:limit].to_i || 10
 
-        offset = (page - 1) * per_page
-
-        # airline_ids = Route.where(destinationairport: destination_airport)
-        #                    #  .distinct(:airlineid)
-        #                    .pluck(:airlineid)
-
-        # airlines = Airline.where(id: airline_ids)
-        #                   .pluck(:callsign, :country, :iata, :icao, :id, :name)
-
-        airlines = Airline.to_airport(destination_airport, limit: per_page, offset:)
-
-        # .offset(offset)
-        # .limit(per_page)
+        airlines = Airline.to_airport(key: [destination_airport])
+                          .pluck(:callsign, :country, :iata, :icao, :name)
 
         formatted_airlines = airlines.map do |airline|
           {

app/models/airline.rb

@@ -9,6 +9,7 @@ class Airline < CouchbaseOrm::Base
   attribute :iata, :string
   attribute :icao, :string
   attribute :country, :string
+  # attribute :destinationAirportCode, :string
 
   validates :name, presence: true
   validates :callsign, presence: true
@@ -18,30 +19,12 @@ class Airline < CouchbaseOrm::Base
 
   # Custom N1QL query to list airlines by country with pagination
   n1ql :list_by_country, emit_key: [:country], query_fn: proc { |bucket, values, options|
-    # limit = options[:limit] || 10
-    # offset = options[:offset] || 0
     cluster.query("SELECT raw meta().id FROM `#{bucket.name}` WHERE type = 'airline' AND country = #{quote(values[0])} LIMIT 10 OFFSET 0", options)
   }
-  # n1ql :by_country,
-  #      "SELECT * FROM `#{bucket.name}` WHERE type = 'airline' AND country = $1 ORDER BY name ASC LIMIT $2 OFFSET $3"
 
-  # SELECT
-  # air.callsign,
-  # air.country,
-  # air.iata,
-  # air.icao,
-  # air.id,
-  # air.name,
-  # air.type
-  # FROM (
-  # SELECT DISTINCT META(airline).id AS airlineId
-  # FROM route
-  # JOIN airline ON route.airlineid = META(airline).id
-  # WHERE route.destinationairport = ?
-  # ) AS subquery
-  # JOIN airline AS air ON META(air).id = subquery.airlineId;
-
-  n1ql :to_airport, emit_key: :icao, query_fn: proc { |bucket, values, options|
-    cluster.query("SELECT raw meta().id FROM `#{bucket.name}` WHERE type = 'airline' AND icao = #{quote(values[0])} LIMIT 10 OFFSET 0", 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 = 'JFK') AS subquery JOIN `#{bucket.name}` AS air ON META(air).id = subquery.airlineId LIMIT 10 OFFSET 0", options)
+                              }
 end