                (assoc-in acc [k :resource] (get refs-to-hashes k)))
              refs-to-resources refs-to-resources))
 
-(pls/defn-validated update-catalog-resources!
+(s/defn update-catalog-resources!
   "Returns a function accepting keys that were the same from the old resources and the new resources."
   [certname-id :- Long
    refs-to-hashes :- {resource-ref-schema String}

     :producer_id (ensure-producer producer)
     :api_version 1}))

(pls/defn-validated update-catalog-metadata!
  "Given some catalog metadata, update the db"
  [id :- Long
   hash :- String

         (update-catalog-metadata! catalog-id hash catalog received-timestamp)
         (update-catalog-associations! certname-id catalog refs-to-hashes)))

(s/defn add-new-catalog
  "Creates new catalog metadata and adds the proper associations for the edges and resources"
  [certname-id :- Long
   hash :- String
