-
Notifications
You must be signed in to change notification settings - Fork 11
/
subscription.go
28 lines (25 loc) · 1.11 KB
/
subscription.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
package base
func init() {
sqlStmts.Subscription.GetForFeed = getFeedHubbubSubscription
sqlStmts.Subscription.All = getHubbubSubscriptions
sqlStmts.Subscription.Create = createHubbubSubscription
sqlStmts.Subscription.Update = updateHubbubSubscription
}
const (
getFeedHubbubSubscription = `
SELECT link, lease_duration, verification_time, subscription_failure
FROM hubbub_subscriptions WHERE feed_id = :feed_id`
getHubbubSubscriptions = `
SELECT link, feed_id, lease_duration, verification_time, subscription_failure
FROM hubbub_subscriptions`
createHubbubSubscription = `
INSERT INTO hubbub_subscriptions(feed_id, link, lease_duration, verification_time, subscription_failure)
SELECT :feed_id, :link, :lease_duration, :verification_time, :subscription_failure EXCEPT
SELECT feed_id, link, lease_duration, verification_time, subscription_failure
FROM hubbub_subscriptions WHERE feed_id = :feed_id
`
updateHubbubSubscription = `
UPDATE hubbub_subscriptions SET link = :link, lease_duration = :lease_duration,
verification_time = :verification_time, subscription_failure = :subscription_failure WHERE feed_id = :feed_id
`
)