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
|
** This file contains code used to deal with moderator actions for
** Wiki and Tickets.
*/
#include "config.h"
#include "moderate.h"
#include <assert.h>
"CREATE TABLE IF NOT EXISTS modreq("
" mreqid INTEGER PRIMARY KEY," /* Unique ID for the request */
" objid INT UNIQUE," /* Record pending approval */
" ctime DATETIME," /* Julian day number */
" user TEXT," /* Name of user submitter */
" ipaddr TEXT," /* IP address of submitter */
" mtype TEXT," /* 't', 'w', 'at', or 'aw' */
" afile INT," /* File being attached, or NULL */
" aid ANY" /* TicketId or Wiki Name */
");"
|
<
|
<
|
>
|
>
>
>
|
>
>
>
>
>
>
>
>
>
>
>
|
>
>
>
>
>
>
>
>
>
>
>
>
>
|
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
|
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
|
>
>
>
>
>
>
>
>
|
>
>
>
>
>
>
>
>
>
>
>
|
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
|
** This file contains code used to deal with moderator actions for
** Wiki and Tickets.
*/
#include "config.h"
#include "moderate.h"
#include <assert.h>
/*
** Create a table to represent pending moderation requests, if the
** table does not already exist.
*/
void moderation_table_create(void){
db_multi_exec(
"CREATE TABLE IF NOT EXISTS modreq(\n"
" objid INTEGER PRIMARY KEY,\n" /* Record pending approval */
" parent INTEGER REFERENCES modreq,\n" /* Parent record */
" tktid TEXT\n" /* Associated ticket id */
");\n"
);
}
/*
** Return TRUE if the modreq table exists
*/
int moderation_table_exists(void){
static int modreqExists = -1;
if( modreqExists<0 ){
modreqExists = db_exists("SELECT 1 FROM %s.sqlite_master"
" WHERE name='modreq'", db_name("repository"));
}
return modreqExists;
}
/*
** Return TRUE if the object specified is being held for moderation.
*/
int moderation_pending(int rid){
static Stmt q;
int rc;
if( rid==0 || !moderation_table_exists() ) return 0;
db_static_prepare(&q, "SELECT 1 FROM modreq WHERE objid=:objid");
db_bind_int(&q, ":objid", rid);
rc = db_step(&q)==SQLITE_ROW;
db_reset(&q);
return rc;
}
/*
** Delete a moderation item given by rid
*/
void moderation_disapprove(int rid){
Stmt q;
char *zTktid;
if( !moderation_pending(rid) ) return;
if( content_is_private(rid) ){
db_prepare(&q, "SELECT rid FROM delta WHERE srcid=%d", rid);
while( db_step(&q)==SQLITE_ROW ){
int ridUser = db_column_int(&q, 0);
content_undelta(ridUser);
}
db_finalize(&q);
db_multi_exec(
"DELETE FROM blob WHERE rid=%d;"
"DELETE FROM delta WHERE rid=%d;"
"DELETE FROM event WHERE objid=%d;"
"DELETE FROM tagxref WHERE rid=%d;"
"DELETE FROM private WHERE rid=%d;",
rid, rid, rid, rid, rid
);
zTktid = db_text(0, "SELECT tktid FROm modreq WHERE objid=%d", rid);
if( zTktid ){
ticket_rebuild_entry(zTktid);
fossil_free(zTktid);
}
}
db_prepare(&q, "SELECT objid FROM modreq WHERE parent=%d AND "
"UNION SELECT parent FROM modreq WHERE objid=%d",
rid, rid);
while( db_step(&q)==SQLITE_ROW ){
int other = db_column_int(&q, 0);
if( other==rid ) continue;
moderation_approve(other);
}
db_finalize(&q);
db_multi_exec("DELETE FROM modreq WHERE objid=%d", rid);
}
/*
** Approve an object held for moderation.
*/
void moderation_approve(int rid){
Stmt q;
if( !moderation_pending(rid) ) return;
db_multi_exec("DELETE FROM private WHERE rid=%d;", rid);
db_prepare(&q, "SELECT objid FROM modreq WHERE parent=%d AND "
"UNION SELECT parent FROM modreq WHERE objid=%d",
rid, rid);
while( db_step(&q)==SQLITE_ROW ){
int other = db_column_int(&q, 0);
if( other==rid ) continue;
moderation_approve(other);
}
db_finalize(&q);
db_multi_exec("DELETE FROM modreq WHERE objid=%d", rid);
}
/*
** WEBPAGE: modreq
**
** Show all pending moderation request
*/
void modreq_page(void){
Blob sql;
Stmt q;
login_check_credentials();
if( !g.perm.RdWiki && !g.perm.RdTkt ){ login_needed(); return; }
style_header("Pending Moderation Requests");
blob_init(&sql, timeline_query_for_www(), -1);
blob_appendf(&sql,
" AND event.objid IN (SELECT objid FROM modreq)"
" ORDER BY event.mtime DESC"
);
db_prepare(&q, blob_str(&sql));
www_print_timeline(&q, 0, 0, 0, 0);
db_finalize(&q);
style_footer();
}
|