1 files changed, 54 insertions, 0 deletions
diff --git a/lib/VNDB/DB/Affiliates.pm b/lib/VNDB/DB/Affiliates.pm
new file mode 100644
index 00000000..2aa891ce
--- /dev/null
+++ b/lib/VNDB/DB/Affiliates.pm
@@ -0,0 +1,54 @@
+
+package VNDB::DB::Affiliates;
+
+use strict;
+use warnings;
+use POSIX 'strftime';
+use Exporter 'import';
+
+our @EXPORT = qw|dbAffiliateGet dbAffiliateEdit dbAffiliateDel dbAffiliateAdd|;
+
+
+# options: id rids affiliate hide_hidden
+# what: release
+sub dbAffiliateGet {
+  my($self, %o) = @_;
+
+  my %where = (
+    $o{id}                 ? ('id = ?' => $o{id}) : (),
+    $o{rids}               ? ('rid IN(!l)'    => [$o{rids}]) : (),
+    defined($o{affiliate}) ? ('affiliate = ?' => $o{affiliate}) : (),
+    $o{hide_hidden}        ? ('NOT hidden'    => 1) : (),
+  );
+
+  my $join = $o{what} ? 'JOIN releases r ON r.id = af.rid JOIN releases_rev rr ON rr.id = r.latest' : '';
+  my $select = $o{what} ? ', rr.title' : '';
+
+  return $self->dbAll("SELECT af.id, af.rid, af.hidden, af.priority, af.affiliate, af.url, af.version, extract('epoch' from af.lastfetch) as lastfetch, af.price$select
+    FROM affiliate_links af $join !W", \%where);
+}
+
+
+sub dbAffiliateDel {
+  my($self, $id) = @_;
+  $self->dbExec('DELETE FROM affiliate_links WHERE id = ?', $id);
+}
+
+
+sub dbAffiliateEdit {
+  my($self, $id, %ops) = @_;
+  my %set;
+  exists($ops{$_}) && ($set{"$_ = ?"} = $ops{$_}) for(qw|rid priority hidden affiliate url version|);
+  return if !keys %set;
+  $self->dbExec('UPDATE affiliate_links !H WHERE id = ?', \%set, $id);
+}
+
+sub dbAffiliateAdd {
+  my($self, %ops) = @_;
+  $self->dbExec('INSERT INTO affiliate_links (rid, priority, hidden, affiliate, url, version) VALUES(!l)',
+    [@ops{qw| rid priority hidden affiliate url version|}]);
+}
+
+
+1;
+