feat: sync with meilisearch for ruby

ruby/meilisearch/Gemfile

@@ -0,0 +1,4 @@
+source "https://rubygems.org"
+
+gem 'appwrite'
+gem 'meilisearch'

ruby/meilisearch/config.rb

@@ -0,0 +1,12 @@
+module Config
+    APPWRITE_ENDPOINT = ENV['APPWRITE_ENDPOINT']
+    APPWRITE_API_KEY = ENV['APPWRITE_API_KEY']
+    APPWRITE_FUNCTION_PROJECT_ID = ENV['APPWRITE_FUNCTION_PROJECT_ID']
+    APPWRITE_DATABASE_ID = ENV['APPWRITE_DATABASE_ID']
+    APPWRITE_COLLECTION_ID = ENV['APPWRITE_COLLECTION_ID']
+    MEILISEARCH_ENDPOINT = ENV['MEILISEARCH_ENDPOINT']
+    MEILISEARCH_INDEX_NAME = ENV['MEILISEARCH_INDEX_NAME']
+    MEILISEARCH_ADMIN_API_KEY = ENV['MEILISEARCH_ADMIN_API_KEY']
+    MEILISEARCH_SEARCH_API_KEY = ENV['MEILISEARCH_SEARCH_API_KEY']
+  end
+

ruby/meilisearch/lib/main.rb

@@ -0,0 +1,46 @@
+require 'appwrite'
+require 'meilisearch'
+require_relative 'config'
+
+appwrite = Appwrite::Client.new
+appwrite
+  .set_endpoint(Config::APPWRITE_ENDPOINT)
+  .set_project(Config::APPWRITE_FUNCTION_PROJECT_ID)
+  .set_key(Config::APPWRITE_API_KEY)
+
+meilisearch = MeiliSearch::Client.new(Config::MEILISEARCH_ENDPOINT, Config::MEILISEARCH_ADMIN_API_KEY)
+
+index_name = Config::MEILISEARCH_INDEX_NAME
+
+database = Appwrite::Database.new(appwrite)
+
+index = meilisearch.index(index_name)
+
+cursor = nil
+
+begin
+  queries = [Appwrite::Query.new.set_limit(100)]
+
+  if cursor
+    queries.push(Appwrite::Query.new.set_cursor(cursor))
+  end
+
+  documents = database.list_documents(
+    Config::APPWRITE_DATABASE_ID,
+    Config::APPWRITE_COLLECTION_ID,
+    queries
+  )
+
+  if documents['documents'].length > 0
+    cursor = documents['documents'].last['$id']
+  else
+    puts 'No more documents found.'
+    cursor = nil
+    break
+  end
+
+  puts "Syncing chunk of #{documents['documents'].length} documents ..."
+  index.add_documents(documents['documents'], primary_key: '$id')
+end while cursor
+
+puts 'Sync finished.'

ruby/meilisearch/lib/utils.rb

@@ -0,0 +1,15 @@
+require 'pathname'
+
+def throw_if_missing(hash, keys)
+  missing = keys.select { |key| !hash.key?(key) || hash[key].nil? }
+  raise "Missing required fields: #{missing.join(', ')}" if missing.any?
+end
+
+def get_static_file(file_name)
+  static_folder = File.join(File.dirname(__FILE__), '../static')
+  File.read(File.join(static_folder, file_name))
+end
+
+def interpolate(template, values)
+  template.gsub(/{{([^}]+)}}/) { |match| values[match[2..-3].strip] || match }
+end