Multimethods

s3.clj

(ns stadig.storage.s3
  (:require
   [aws.sdk.s3 :as s3]
   [stadig.storage.methods :as methods]))

(defmethod methods/get :s3
  [this bucket key]
  (when-not bucket
    (throw (ex-info "Expected bucket" {:type ::bucket-error})))
  (s3/get-object this bucket key))

(defmethod methods/put :s3
  [this bucket key value]
  (when-not bucket
    (throw (ex-info "Expected bucket" {:type ::bucket-error})))
  (s3/put-object this bucket key value))

(defmethod methods/delete :s3
  [this bucket key]
  (when-not bucket
    (throw (ex-info "Expected bucket" {:type ::bucket-error})))
  (s3/delete-object this bucket key))

(defmethod methods/close :s3
  [this])

(defn connect
  [access-key secret-key]
  {:backend :s3 :access-key access-key :secret-key secret-key})