-
Notifications
You must be signed in to change notification settings - Fork 2
/
data.cljc
180 lines (158 loc) · 7.96 KB
/
data.cljc
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
(ns sb.app.membership.data
(:require [sb.app.entity.data :as entity.data]
[sb.authorize :as az]
[sb.query :as q]
[sb.schema :as sch :refer [? s-]]
[sb.server.datalevin :as dl]
[sb.util :as u]
[re-db.api :as db])
#?(:clj (:import [java.util Date])))
(sch/register!
{:roles/as-map {s- :membership/as-map}
:membership/entity+member (merge {:db/tupleAttrs [:membership/entity :membership/member]}
sch/unique-value)
:membership/_entity {s- [:or
:membership/as-map
[:sequential
:membership/as-map]]}
:membership/role {s- [:enum
:role/admin
:role/editor
:role/member]}
:membership/roles (merge sch/keyword
sch/many
{s- [:set :membership/role]})
:membership/entity (sch/ref :one)
:membership/member (sch/ref :one)
:entity/tags {s- [:sequential [:map {:closed true} :tag/id]]}
:entity/custom-tags {s- [:sequential [:map {:closed true} :tag/label]]}
;; TODO: move/remove. this should simply be a field that an organizer adds.
:membership/newsletter-subscription? {s- :boolean},
;; TODO: move email-frequency to a separate place (focused on notifications)
:membership/email-frequency {s- [:enum
:member.email-frequency/never
:member.email-frequency/daily
:member.email-frequency/periodic
:member.email-frequency/instant]}
;; TODO: better define this state.
;; - used for people who are no longer attending / need to be managed by organizers.
;; - different than deleted - user can still sign in to reactivate?
:membership/inactive? {:doc "Marks a member inactive, hidden."
:admin true
:todo "If an inactive member signs in to a board, mark as active again?"
s- :boolean},
:membership/as-map {s- [:map {:closed true}
:entity/id
:entity/kind
:membership/entity
:membership/member
(? :entity/uploads)
(? :membership/inactive?)
(? :membership/email-frequency)
(? :entity/custom-tags)
(? :membership/newsletter-subscription?)
(? :entity/tags)
(? :membership/roles)
;; TODO, backfill?
(? :entity/created-at)
(? :entity/updated-at)
(? :entity/field-entries)
(? :entity/deleted-at)
(? :entity/modified-by)]}})
(q/defquery show
{:prepare az/require-account!}
[params]
(dissoc (q/pull `[~@entity.data/listing-fields
:entity/tags
:entity/field-entries
{:membership/entity [:entity/id
:entity/kind
:entity/member-tags
:entity/member-fields]}
{:membership/member [~@entity.data/listing-fields
:account/display-name]}]
(:membership-id params))))
(defn membership-id [member-id entity-id]
[:entity/id (sch/composite-uuid :membership member-id entity-id)])
(def membership (comp db/entity membership-id))
#?(:clj
(defn ensure-membership! [account entity]
(let [entity (dl/entity entity)]
(case (:entity/kind entity)
:project (ensure-membership! account (:entity/parent entity))
(when-not (dl/resolve-id (membership-id account entity))
(throw (ex-info "Not a member" {:status 403})))))))
(defn active-member? [member]
(and (not (:membership/inactive? member))
(not (:entity/deleted-at member))))
#?(:clj
(defn can-view? [account-id entity]
(let [kind (:entity/kind entity)]
(case kind
(:board :org) (or (:entity/public? entity)
(active-member? (membership account-id entity)))
:project (can-view? account-id (:entity/parent entity))
:membership (let [member (:membership/member entity)]
(case (:entity/kind member)
:account (sch/id= account-id member)
:membership (can-view? account-id (:membership/entity entity))))))))
#?(:clj
(defn assert-can-view [id-key]
(fn assert-can-view* [req params]
(let [entity (dl/entity (id-key params))]
(when-not (can-view? (:account-id params) entity)
(az/unauthorized! (str "Not authorized to view this "
(:entity/kind entity "entity."))))))))
(q/defquery descriptions
{:endpoint {:query true}
:prepare az/with-account-id!}
[{:as params :keys [account-id ids]}]
(u/timed `descriptions
(into []
(comp (map (comp db/entity sch/wrap-id))
(filter active-member?)
(map (db/pull `[~@entity.data/listing-fields
:entity/public?])))
ids)))
(q/defquery search
{:prepare [az/with-account-id!]}
[{:as params :keys [account-id entity-id search-term]}]
(if entity-id
;; scoped to entity
(do
(ensure-membership! account-id entity-id)
(dl/q '[:find [(pull ?account [:account/display-name
:entity/id
{:image/avatar [:entity/id]}]) ...]
:in $ ?entity ?search-term
:where
[?m :membership/entity ?entity]
[?m :membership/member ?account]
[(fulltext $ ?search-term {:top 20}) [[?account ?a ?v]]]]
entity-id
search-term))
;; all entities I'm also a member of
(dl/q '[:find [(pull ?your-account [:account/display-name
:entity/id
{:image/avatar [:entity/id]}]) ...]
:in $ ?my-account ?search-term
:where
[?me :membership/member ?my-account]
[?me :membership/entity ?entity]
[?you :membership/entity ?entity]
[?you :membership/member ?your-account]
[(fulltext $ ?search-term {:top 20}) [[?your-account ?a ?v]]]]
account-id
search-term)))
(comment
(search {:account-id [:entity/id #uuid "b08f39bf-4f31-3d0b-87a6-ef6a2f702d30"]
;:entity-id [:entity/id #uuid "a1630339-64b3-3604-8110-0f22355e12be"]
:search-term "matt"}))
(defn new-entity-with-membership [entity account-id roles]
{:entity/id (random-uuid)
:entity/kind :membership
:membership/member (sch/wrap-id account-id)
:membership/entity entity
:membership/roles roles})
(comment
@(db/entity [:entity/id #uuid "102d77ed-2b62-309c-b33b-b033cc07a008"]))