biiwide / sandboxica Goto Github PK

(def s3-req
  (let [some-bytes (.getBytes "<h1>HI</h1>")]
    {:bucket-name    "mybucket"
     :key            "something.txt"
     :input-stream   (java.io.ByteArrayInputStream. some-bytes)
     :metadata       {:content-type   "text/html"
                      :content-length (count some-bytes)
                      :user-metadata  {"somethin" "some-value"}}}))

;; When I override the put-object method on the amazonica s3 client, the
;; intercepted request reflects that the request was not intercepted properly
(sandbox/with (sandbox/just
               (s3/put-object
                ([req] (println "REQUEST" (type req) req))))
  (s3/put-object {:profile "none"} s3-req))
;; => Running this code prints out the following `{:requester-pays? false}`, but is missing all of the supplied fields

;;  The `sandboxica/coerce-method-implementation` directly calls `aws/marshall` on the incoming clojure map (`s3-req` in this case)
;;  When `aws/marshall` is called directly on a Clojure map representing PutObjectRequest, it does not marshall resources properly
(aws/marshall (#'aws/create-bean com.amazonaws.services.s3.model.PutObjectRequest
                                 s3-req))
;; => {:requester-pays? false}

(let [method
      (#'aws/best-method (:put-object (#'aws/client-methods com.amazonaws.services.s3.AmazonS3Client))
                         [{:profile "none"} s3-req])]
  (bean (first (seq (aws/marshall (#'aws/prepare-args method [s3-req]))))))
;; => {:cloneSource nil,
;;     :storageClass nil,
;;     :key "something.txt",
;;     :customQueryParameters nil,
;;     :file nil,
;;     :readLimit 131073,
;;     :inputStream
;;     #object[java.io.ByteArrayInputStream 0x1f9a0a26 "java.io.ByteArrayInputStream@1f9a0a26"],
;;     :requestCredentials nil,
;;     :objectLockRetainUntilDate nil,
;;     :sdkClientExecutionTimeout nil,
;;     :generalProgressListener
;;     #object[com.amazonaws.event.ProgressListener$NoOpProgressListener 0x775e743b "com.amazonaws.event.ProgressListener$NoOpProgressListener@775e743b"],
;;     :SSECustomerKey nil,
;;     :cloneRoot nil,
;;     :class com.amazonaws.services.s3.model.PutObjectRequest,
;;     :accessControlList nil,
;;     :progressListener nil,
;;     :cannedAcl nil,
;;     :requestClientOptions
;;     #object[com.amazonaws.RequestClientOptions 0x192557b7 "com.amazonaws.RequestClientOptions@192557b7"],
;;     :bucketName "mybucket",
;;     :sdkRequestTimeout nil,
;;     :tagging nil,
;;     :requesterPays false,
;;     :SSEAwsKeyManagementParams nil,
;;     :redirectLocation nil,
;;     :requestMetricCollector nil,
;;     :customRequestHeaders nil,
;;     :metadata
;;     #object[com.amazonaws.services.s3.model.ObjectMetadata 0x58977f3d "com.amazonaws.services.s3.model.ObjectMetadata@58977f3d"],
;;     :requestCredentialsProvider nil,
;;     :objectLockLegalHoldStatus nil,
;;     :objectLockMode nil}