0000: 2d 2d 20 6d 6f 64 75 6c 65 20 63 6f 75 6e 74 65 -- module counte
0010: 72 20 2d 20 63 6f 75 6e 74 73 20 73 6f 6d 65 20 r - counts some
0020: 6a 75 6e 6b 0a 0a 6c 6f 63 61 6c 20 5f 63 6f 75 junk..local _cou
0030: 6e 74 65 72 20 3d 20 7b 7d 0a 0a 6c 6f 63 61 6c nter = {}..local
0040: 20 72 65 64 69 73 20 3d 20 72 65 71 75 69 72 65 redis = require
0050: 20 27 72 65 73 74 79 2e 72 65 64 69 73 27 0a 6c 'resty.redis'.l
0060: 6f 63 61 6c 20 63 6a 73 6f 6e 20 3d 20 72 65 71 ocal cjson = req
0070: 75 69 72 65 20 27 63 6a 73 6f 6e 27 0a 0a 6c 6f uire 'cjson'..lo
0080: 63 61 6c 20 63 6c 6f 73 65 64 20 3d 20 66 61 6c cal closed = fal
0090: 73 65 0a 0a 66 75 6e 63 74 69 6f 6e 20 5f 63 6f se..function _co
00a0: 75 6e 74 65 72 2e 65 78 69 74 28 29 0a 09 69 66 unter.exit()..if
00b0: 20 6e 6f 74 20 63 6c 6f 73 65 64 20 74 68 65 6e not closed then
00c0: 0a 09 09 6c 6f 63 61 6c 20 6f 6b 2c 20 65 72 72 ...local ok, err
00d0: 20 3d 20 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a = _counter.red:
00e0: 73 65 74 5f 6b 65 65 70 61 6c 69 76 65 28 36 30 set_keepalive(60
00f0: 30 30 30 2c 20 31 30 29 0a 09 09 69 66 20 6e 6f 000, 10)...if no
0100: 74 20 6f 6b 20 74 68 65 6e 0a 09 09 09 6e 67 78 t ok then....ngx
0110: 2e 6c 6f 67 28 6e 67 78 2e 45 52 52 2c 20 22 72 .log(ngx.ERR, "r
0120: 65 64 69 73 20 6b 65 65 70 61 6c 69 76 65 3a 20 edis keepalive:
0130: 22 20 2e 2e 20 65 72 72 29 0a 09 09 65 6e 64 0a " .. err)...end.
0140: 09 09 63 6c 6f 73 65 64 20 3d 20 74 72 75 65 0a ..closed = true.
0150: 09 65 6e 64 0a 65 6e 64 0a 0a 66 75 6e 63 74 69 .end.end..functi
0160: 6f 6e 20 5f 63 6f 75 6e 74 65 72 2e 64 65 63 6f on _counter.deco
0170: 64 65 5f 62 75 6c 6b 28 72 65 70 6c 79 29 0a 09 de_bulk(reply)..
0180: 2d 2d 20 64 65 63 6f 64 65 73 20 76 61 6c 75 65 -- decodes value
0190: 73 20 66 72 6f 6d 20 61 72 72 61 79 20 69 6e 74 s from array int
01a0: 6f 20 64 69 63 74 0a 09 6c 6f 63 61 6c 20 64 61 o dict..local da
01b0: 74 61 20 3d 20 7b 7d 0a 09 66 6f 72 20 6a 3d 31 ta = {}..for j=1
01c0: 2c 20 23 72 65 70 6c 79 2c 20 32 20 64 6f 0a 09 , #reply, 2 do..
01d0: 09 64 61 74 61 5b 72 65 70 6c 79 5b 6a 5d 20 5d .data[reply[j] ]
01e0: 20 3d 20 72 65 70 6c 79 5b 6a 2b 31 5d 0a 09 65 = reply[j+1]..e
01f0: 6e 64 0a 09 72 65 74 75 72 6e 20 64 61 74 61 0a nd..return data.
0200: 65 6e 64 0a 0a 66 75 6e 63 74 69 6f 6e 20 5f 63 end..function _c
0210: 6f 75 6e 74 65 72 2e 63 6f 6e 6e 65 63 74 28 29 ounter.connect()
0220: 0a 09 2d 2d 20 63 6f 6e 6e 65 63 74 20 74 6f 20 ..-- connect to
0230: 72 65 64 69 73 0a 09 5f 63 6f 75 6e 74 65 72 2e redis.._counter.
0240: 72 65 64 20 3d 20 72 65 64 69 73 3a 6e 65 77 28 red = redis:new(
0250: 29 0a 09 6c 6f 63 61 6c 20 6f 6b 2c 20 65 72 72 )..local ok, err
0260: 20 3d 20 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a = _counter.red:
0270: 63 6f 6e 6e 65 63 74 28 27 31 32 37 2e 30 2e 30 connect('127.0.0
0280: 2e 31 27 2c 20 36 33 37 39 29 0a 09 69 66 20 6e .1', 6379)..if n
0290: 6f 74 20 6f 6b 20 74 68 65 6e 0a 09 09 6e 67 78 ot ok then...ngx
02a0: 2e 6c 6f 67 28 6e 67 78 2e 45 52 52 2c 20 27 72 .log(ngx.ERR, 'r
02b0: 65 64 69 73 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 edis connection
02c0: 66 61 69 6c 65 64 3a 20 27 2c 20 65 72 72 29 0a failed: ', err).
02d0: 09 09 6e 67 78 2e 65 78 69 74 28 6e 67 78 2e 48 ..ngx.exit(ngx.H
02e0: 54 54 50 5f 49 4e 54 45 52 4e 41 4c 5f 53 45 52 TTP_INTERNAL_SER
02f0: 56 45 52 5f 45 52 52 4f 52 29 0a 09 65 6e 64 0a VER_ERROR)..end.
0300: 09 63 6c 6f 73 65 64 20 3d 20 66 61 6c 73 65 0a .closed = false.
0310: 65 6e 64 0a 0a 66 75 6e 63 74 69 6f 6e 20 5f 63 end..function _c
0320: 6f 75 6e 74 65 72 2e 63 68 65 63 6b 5f 73 63 68 ounter.check_sch
0330: 65 6d 61 28 29 0a 09 69 66 20 6e 67 78 2e 76 61 ema()..if ngx.va
0340: 72 2e 73 69 74 65 5f 73 63 68 65 6d 61 20 3d 3d r.site_schema ==
0350: 20 6e 69 6c 20 74 68 65 6e 0a 09 09 6e 67 78 2e nil then...ngx.
0360: 6c 6f 67 28 6e 67 78 2e 45 52 52 2c 20 22 4e 6f log(ngx.ERR, "No
0370: 20 27 73 69 74 65 5f 73 63 68 65 6d 61 27 20 73 'site_schema' s
0380: 70 65 63 69 66 69 65 64 22 29 3b 0a 09 09 6e 67 pecified");...ng
0390: 78 2e 65 78 69 74 28 6e 67 78 2e 48 54 54 50 5f x.exit(ngx.HTTP_
03a0: 49 4e 54 45 52 4e 41 4c 5f 53 45 52 56 45 52 5f INTERNAL_SERVER_
03b0: 45 52 52 4f 52 29 0a 09 65 6e 64 0a 65 6e 64 0a ERROR)..end.end.
03c0: 0a 66 75 6e 63 74 69 6f 6e 20 5f 63 6f 75 6e 74 .function _count
03d0: 65 72 2e 75 70 64 61 74 65 28 29 0a 09 5f 63 6f er.update().._co
03e0: 75 6e 74 65 72 2e 63 68 65 63 6b 5f 73 63 68 65 unter.check_sche
03f0: 6d 61 28 29 0a 09 6c 6f 63 61 6c 20 74 6f 64 61 ma()..local toda
0400: 79 20 3d 20 6f 73 2e 64 61 74 65 28 27 2a 74 27 y = os.date('*t'
0410: 29 0a 09 6c 6f 63 61 6c 20 74 69 6d 65 73 74 61 )..local timesta
0420: 6d 70 20 3d 20 6f 73 2e 74 69 6d 65 7b 79 65 61 mp = os.time{yea
0430: 72 20 3d 20 74 6f 64 61 79 5b 27 79 65 61 72 27 r = today['year'
0440: 5d 2c 20 6d 6f 6e 74 68 20 3d 20 74 6f 64 61 79 ], month = today
0450: 5b 27 6d 6f 6e 74 68 27 5d 2c 20 64 61 79 20 3d ['month'], day =
0460: 20 74 6f 64 61 79 5b 27 64 61 79 27 5d 7d 0a 09 today['day']}..
0470: 6c 6f 63 61 6c 20 72 65 66 65 72 65 72 20 3d 20 local referer =
0480: 27 2d 27 3b 0a 0a 09 69 66 20 6e 67 78 2e 76 61 '-';...if ngx.va
0490: 72 2e 68 74 74 70 5f 72 65 66 65 72 65 72 20 7e r.http_referer ~
04a0: 3d 20 6e 69 6c 20 74 68 65 6e 0a 09 09 5f 2c 20 = nil then..._,
04b0: 5f 2c 20 72 65 66 65 72 65 72 20 3d 20 73 74 72 _, referer = str
04c0: 69 6e 67 2e 66 69 6e 64 28 6e 67 78 2e 76 61 72 ing.find(ngx.var
04d0: 2e 68 74 74 70 5f 72 65 66 65 72 65 72 2c 20 27 .http_referer, '
04e0: 5e 68 74 74 70 73 3f 3a 2f 2f 28 5b 5e 3f 26 5d ^https?://([^?&]
04f0: 2b 29 27 29 0a 09 09 2d 2d 6e 67 78 2e 6c 6f 67 +)')...--ngx.log
0500: 28 6e 67 78 2e 45 52 52 2c 20 22 52 65 66 65 72 (ngx.ERR, "Refer
0510: 65 72 3a 20 22 20 2e 2e 20 72 65 66 65 72 65 72 er: " .. referer
0520: 29 0a 09 65 6e 64 0a 0a 09 6c 6f 63 61 6c 20 6b )..end...local k
0530: 65 79 20 3d 20 6e 67 78 2e 76 61 72 2e 73 69 74 ey = ngx.var.sit
0540: 65 5f 73 63 68 65 6d 61 20 2e 2e 20 27 5f 63 6f e_schema .. '_co
0550: 75 6e 74 65 72 5f 27 20 2e 2e 20 74 69 6d 65 73 unter_' .. times
0560: 74 61 6d 70 20 2e 2e 20 27 5f 27 20 2e 2e 20 72 tamp .. '_' .. r
0570: 65 66 65 72 65 72 0a 09 2d 2d 20 6e 67 78 2e 6c eferer..-- ngx.l
0580: 6f 67 28 6e 67 78 2e 45 52 52 2c 20 22 55 73 69 og(ngx.ERR, "Usi
0590: 6e 67 20 6b 65 79 3a 20 22 20 2e 2e 20 6b 65 79 ng key: " .. key
05a0: 29 0a 0a 09 6c 6f 63 61 6c 20 72 65 73 2c 20 65 )...local res, e
05b0: 72 72 0a 09 5f 63 6f 75 6e 74 65 72 2e 72 65 64 rr.._counter.red
05c0: 3a 69 6e 69 74 5f 70 69 70 65 6c 69 6e 65 28 34 :init_pipeline(4
05d0: 29 0a 09 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a ).._counter.red:
05e0: 6d 75 6c 74 69 28 29 0a 09 5f 63 6f 75 6e 74 65 multi().._counte
05f0: 72 2e 72 65 64 3a 68 69 6e 63 72 62 79 28 6b 65 r.red:hincrby(ke
0600: 79 2c 20 27 74 6f 64 61 79 27 2c 20 31 29 0a 09 y, 'today', 1)..
0610: 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a 68 67 65 _counter.red:hge
0620: 74 61 6c 6c 28 6b 65 79 29 0a 09 5f 63 6f 75 6e tall(key).._coun
0630: 74 65 72 2e 72 65 64 3a 65 78 65 63 28 29 0a 09 ter.red:exec()..
0640: 72 65 73 2c 20 65 72 72 20 3d 20 5f 63 6f 75 6e res, err = _coun
0650: 74 65 72 2e 72 65 64 3a 63 6f 6d 6d 69 74 5f 70 ter.red:commit_p
0660: 69 70 65 6c 69 6e 65 28 29 0a 09 69 66 20 6e 6f ipeline()..if no
0670: 74 20 72 65 73 20 74 68 65 6e 0a 09 09 6e 67 78 t res then...ngx
0680: 2e 6c 6f 67 28 6e 67 78 2e 45 52 52 2c 20 27 72 .log(ngx.ERR, 'r
0690: 65 64 69 73 20 70 69 70 65 6c 69 6e 65 20 66 61 edis pipeline fa
06a0: 69 6c 65 64 3a 20 27 2c 20 65 72 72 29 0a 09 09 iled: ', err)...
06b0: 6e 67 78 2e 65 78 69 74 28 6e 67 78 2e 48 54 54 ngx.exit(ngx.HTT
06c0: 50 5f 49 4e 54 45 52 4e 41 4c 5f 53 45 52 56 45 P_INTERNAL_SERVE
06d0: 52 5f 45 52 52 4f 52 29 0a 09 65 6e 64 0a 0a 09 R_ERROR)..end...
06e0: 6c 6f 63 61 6c 20 64 61 74 61 20 3d 20 5f 63 6f local data = _co
06f0: 75 6e 74 65 72 2e 72 65 64 3a 61 72 72 61 79 5f unter.red:array_
0700: 74 6f 5f 68 61 73 68 28 72 65 73 5b 34 5d 5b 32 to_hash(res[4][2
0710: 5d 29 0a 09 2d 2d 20 6e 67 78 2e 6c 6f 67 28 6e ])..-- ngx.log(n
0720: 67 78 2e 45 52 52 2c 20 22 47 6f 74 20 64 61 74 gx.ERR, "Got dat
0730: 61 3a 20 22 20 2e 2e 20 63 6a 73 6f 6e 2e 65 6e a: " .. cjson.en
0740: 63 6f 64 65 28 64 61 74 61 29 29 0a 0a 09 69 66 code(data))...if
0750: 20 74 6f 6e 75 6d 62 65 72 28 64 61 74 61 2e 74 tonumber(data.t
0760: 6f 64 61 79 29 20 3d 3d 20 31 20 74 68 65 6e 0a oday) == 1 then.
0770: 09 09 6e 67 78 2e 6c 6f 67 28 6e 67 78 2e 45 52 ..ngx.log(ngx.ER
0780: 52 2c 20 22 52 65 61 64 69 6e 67 20 70 6f 73 74 R, "Reading post
0790: 67 72 65 73 22 29 0a 09 09 2d 2d 20 70 6f 73 74 gres")...-- post
07a0: 67 72 65 73 20 66 61 6c 6c 62 61 63 6b 0a 09 09 gres fallback...
07b0: 72 65 73 75 6c 74 20 3d 20 6e 67 78 2e 6c 6f 63 result = ngx.loc
07c0: 61 74 69 6f 6e 2e 63 61 70 74 75 72 65 28 27 2f ation.capture('/
07d0: 70 6f 73 74 67 72 65 73 27 2c 20 7b 0a 09 09 09 postgres', {....
07e0: 6d 65 74 68 6f 64 20 3d 20 6e 67 78 2e 48 54 54 method = ngx.HTT
07f0: 50 5f 50 55 54 2c 0a 09 09 09 62 6f 64 79 20 3d P_PUT,....body =
0800: 20 22 73 65 6c 65 63 74 20 2a 20 66 72 6f 6d 20 "select * from
0810: 22 20 2e 2e 20 6e 67 78 2e 76 61 72 2e 73 69 74 " .. ngx.var.sit
0820: 65 5f 73 63 68 65 6d 61 20 2e 2e 20 22 2e 67 65 e_schema .. ".ge
0830: 74 5f 73 74 61 74 73 28 27 22 20 2e 2e 20 72 65 t_stats('" .. re
0840: 66 65 72 65 72 20 2e 2e 20 22 27 29 20 61 73 20 ferer .. "') as
0850: 28 74 6f 64 61 79 20 69 6e 74 2c 20 6c 61 73 74 (today int, last
0860: 64 61 79 20 69 6e 74 2c 20 77 65 65 6b 20 62 69 day int, week bi
0870: 67 69 6e 74 2c 20 77 68 6f 6c 65 20 62 69 67 69 gint, whole bigi
0880: 6e 74 29 3b 22 0a 09 09 7d 29 0a 09 09 69 66 20 nt);"...})...if
0890: 72 65 73 75 6c 74 2e 73 74 61 74 75 73 20 7e 3d result.status ~=
08a0: 20 32 30 30 20 6f 72 20 6e 6f 74 20 72 65 73 75 200 or not resu
08b0: 6c 74 2e 62 6f 64 79 20 74 68 65 6e 0a 09 09 09 lt.body then....
08c0: 6e 67 78 2e 6c 6f 67 28 6e 67 78 2e 45 52 52 2c ngx.log(ngx.ERR,
08d0: 20 27 70 6f 73 74 67 72 65 73 20 61 63 63 65 73 'postgres acces
08e0: 73 20 66 61 69 6c 65 64 27 29 0a 09 09 09 6e 67 s failed')....ng
08f0: 78 2e 65 78 69 74 28 6e 67 78 2e 48 54 54 50 5f x.exit(ngx.HTTP_
0900: 49 4e 54 45 52 4e 41 4c 5f 53 45 52 56 45 52 5f INTERNAL_SERVER_
0910: 45 52 52 4f 52 29 0a 09 09 65 6c 73 65 0a 09 09 ERROR)...else...
0920: 09 6c 6f 63 61 6c 20 75 6e 72 64 73 20 3d 20 72 .local unrds = r
0930: 65 71 75 69 72 65 20 22 72 64 73 2e 70 61 72 73 equire "rds.pars
0940: 65 72 22 0a 09 09 09 6c 6f 63 61 6c 20 72 65 73 er"....local res
0950: 2c 20 65 72 72 20 3d 20 75 6e 72 64 73 2e 70 61 , err = unrds.pa
0960: 72 73 65 28 72 65 73 75 6c 74 2e 62 6f 64 79 29 rse(result.body)
0970: 0a 0a 09 09 09 69 66 20 72 65 73 20 3d 3d 20 6e .....if res == n
0980: 69 6c 20 74 68 65 6e 0a 09 09 09 09 6e 67 78 2e il then.....ngx.
0990: 6c 6f 67 28 6e 67 78 2e 45 52 52 2c 20 27 66 61 log(ngx.ERR, 'fa
09a0: 69 6c 65 64 20 74 6f 20 6f 62 74 61 69 6e 20 64 iled to obtain d
09b0: 61 74 61 3a 20 27 20 2e 2e 20 65 72 72 29 0a 09 ata: ' .. err)..
09c0: 09 09 09 6e 67 78 2e 65 78 69 74 28 6e 67 78 2e ...ngx.exit(ngx.
09d0: 48 54 54 50 5f 49 4e 54 45 52 4e 41 4c 5f 53 45 HTTP_INTERNAL_SE
09e0: 52 56 45 52 5f 45 52 52 4f 52 29 0a 09 09 09 65 RVER_ERROR)....e
09f0: 6c 73 65 0a 09 09 09 09 64 61 74 61 20 3d 20 72 lse.....data = r
0a00: 65 73 2e 72 65 73 75 6c 74 73 65 74 5b 31 5d 0a es.resultset[1].
0a10: 09 09 09 09 64 61 74 61 2e 74 6f 64 61 79 20 3d ....data.today =
0a20: 20 64 61 74 61 2e 74 6f 64 61 79 20 2b 20 31 0a data.today + 1.
0a30: 09 09 09 09 6e 67 78 2e 6c 6f 67 28 6e 67 78 2e ....ngx.log(ngx.
0a40: 45 52 52 2c 20 22 47 6f 74 20 64 61 74 61 3a 20 ERR, "Got data:
0a50: 22 20 2e 2e 20 63 6a 73 6f 6e 2e 65 6e 63 6f 64 " .. cjson.encod
0a60: 65 28 64 61 74 61 29 29 0a 0a 09 09 09 09 5f 63 e(data))......_c
0a70: 6f 75 6e 74 65 72 2e 72 65 64 3a 69 6e 69 74 5f ounter.red:init_
0a80: 70 69 70 65 6c 69 6e 65 28 34 29 0a 09 09 09 09 pipeline(4).....
0a90: 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a 6d 75 6c _counter.red:mul
0aa0: 74 69 28 29 0a 09 09 09 09 5f 63 6f 75 6e 74 65 ti()....._counte
0ab0: 72 2e 72 65 64 3a 68 6d 73 65 74 28 6b 65 79 2c r.red:hmset(key,
0ac0: 20 64 61 74 61 29 0a 09 09 09 09 5f 63 6f 75 6e data)....._coun
0ad0: 74 65 72 2e 72 65 64 3a 65 78 70 69 72 65 28 6b ter.red:expire(k
0ae0: 65 79 2c 20 31 32 39 36 30 30 29 0a 09 09 09 09 ey, 129600).....
0af0: 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a 65 78 65 _counter.red:exe
0b00: 63 28 29 0a 09 09 09 09 72 65 73 2c 20 65 72 72 c().....res, err
0b10: 20 3d 20 5f 63 6f 75 6e 74 65 72 2e 72 65 64 3a = _counter.red:
0b20: 63 6f 6d 6d 69 74 5f 70 69 70 65 6c 69 6e 65 28 commit_pipeline(
0b30: 29 0a 09 09 09 09 69 66 20 6e 6f 74 20 72 65 73 ).....if not res
0b40: 20 74 68 65 6e 0a 09 09 09 09 09 6e 67 78 2e 6c then......ngx.l
0b50: 6f 67 28 6e 67 78 2e 45 52 52 2c 20 27 72 65 64 og(ngx.ERR, 'red
0b60: 69 73 20 70 69 70 65 6c 69 6e 65 20 66 61 69 6c is pipeline fail
0b70: 65 64 3a 20 27 2c 20 65 72 72 29 0a 09 09 09 09 ed: ', err).....
0b80: 09 6e 67 78 2e 65 78 69 74 28 6e 67 78 2e 48 54 .ngx.exit(ngx.HT
0b90: 54 50 5f 49 4e 54 45 52 4e 41 4c 5f 53 45 52 56 TP_INTERNAL_SERV
0ba0: 45 52 5f 45 52 52 4f 52 29 0a 09 09 09 09 65 6e ER_ERROR).....en
0bb0: 64 0a 09 09 09 65 6e 64 0a 09 09 65 6e 64 0a 09 d....end...end..
0bc0: 65 6e 64 0a 0a 09 6e 67 78 2e 73 61 79 28 63 6a end...ngx.say(cj
0bd0: 73 6f 6e 2e 65 6e 63 6f 64 65 28 64 61 74 61 29 son.encode(data)
0be0: 29 0a 09 6e 67 78 2e 65 6f 66 28 29 0a 0a 09 6c )..ngx.eof()...l
0bf0: 6f 63 61 6c 20 75 69 64 20 3d 20 27 27 0a 0a 09 ocal uid = ''...
0c00: 69 66 20 6e 67 78 2e 76 61 72 2e 75 69 64 5f 67 if ngx.var.uid_g
0c10: 6f 74 20 7e 3d 20 6e 69 6c 20 61 6e 64 20 73 74 ot ~= nil and st
0c20: 72 69 6e 67 2e 66 69 6e 64 28 6e 67 78 2e 76 61 ring.find(ngx.va
0c30: 72 2e 75 69 64 5f 67 6f 74 2c 20 27 75 69 64 3d r.uid_got, 'uid=
0c40: 27 29 20 3d 3d 20 31 20 74 68 65 6e 0a 09 09 75 ') == 1 then...u
0c50: 69 64 20 3d 20 73 74 72 69 6e 67 2e 73 75 62 28 id = string.sub(
0c60: 6e 67 78 2e 76 61 72 2e 75 69 64 5f 67 6f 74 2c ngx.var.uid_got,
0c70: 20 35 29 0a 09 65 6c 73 65 69 66 20 6e 67 78 2e 5)..elseif ngx.
0c80: 76 61 72 2e 75 69 64 5f 73 65 74 20 7e 3d 20 6e var.uid_set ~= n
0c90: 69 6c 20 61 6e 64 20 73 74 72 69 6e 67 2e 66 69 il and string.fi
0ca0: 6e 64 28 6e 67 78 2e 76 61 72 2e 75 69 64 5f 73 nd(ngx.var.uid_s
0cb0: 65 74 2c 20 27 75 69 64 3d 27 29 20 3d 3d 20 31 et, 'uid=') == 1
0cc0: 20 74 68 65 6e 0a 09 09 75 69 64 20 3d 20 73 74 then...uid = st
0cd0: 72 69 6e 67 2e 73 75 62 28 6e 67 78 2e 76 61 72 ring.sub(ngx.var
0ce0: 2e 75 69 64 5f 73 65 74 2c 20 35 29 0a 09 65 6e .uid_set, 5)..en
0cf0: 64 0a 0a 09 6c 6f 63 61 6c 20 68 69 74 5f 6b 65 d...local hit_ke
0d00: 79 20 3d 20 75 69 64 20 2e 2e 20 27 5f 27 20 2e y = uid .. '_' .
0d10: 2e 20 72 65 66 65 72 65 72 20 2e 2e 20 27 5f 27 . referer .. '_'
0d20: 20 2e 2e 20 6e 67 78 2e 76 61 72 2e 72 65 6d 6f .. ngx.var.remo
0d30: 74 65 5f 61 64 64 72 0a 09 6c 6f 63 61 6c 20 6b te_addr..local k
0d40: 65 79 5f 70 65 6e 64 69 6e 67 20 3d 20 6e 67 78 ey_pending = ngx
0d50: 2e 76 61 72 2e 73 69 74 65 5f 73 63 68 65 6d 61 .var.site_schema
0d60: 20 2e 2e 20 27 5f 63 6f 75 6e 74 65 72 5f 70 65 .. '_counter_pe
0d70: 6e 64 69 6e 67 27 0a 0a 09 5f 63 6f 75 6e 74 65 nding'..._counte
0d80: 72 2e 72 65 64 3a 69 6e 69 74 5f 70 69 70 65 6c r.red:init_pipel
0d90: 69 6e 65 28 34 29 0a 09 5f 63 6f 75 6e 74 65 72 ine(4).._counter
0da0: 2e 72 65 64 3a 6d 75 6c 74 69 28 29 0a 09 5f 63 .red:multi().._c
0db0: 6f 75 6e 74 65 72 2e 72 65 64 3a 68 69 6e 63 72 ounter.red:hincr
0dc0: 62 79 28 6b 65 79 5f 70 65 6e 64 69 6e 67 2c 20 by(key_pending,
0dd0: 68 69 74 5f 6b 65 79 2c 20 31 29 0a 09 5f 63 6f hit_key, 1).._co
0de0: 75 6e 74 65 72 2e 72 65 64 3a 65 78 70 69 72 65 unter.red:expire
0df0: 28 6b 65 79 5f 70 65 6e 64 69 6e 67 2c 20 36 30 (key_pending, 60
0e00: 34 38 30 30 29 0a 09 5f 63 6f 75 6e 74 65 72 2e 4800).._counter.
0e10: 72 65 64 3a 65 78 65 63 28 29 0a 09 72 65 73 2c red:exec()..res,
0e20: 20 65 72 72 20 3d 20 5f 63 6f 75 6e 74 65 72 2e err = _counter.
0e30: 72 65 64 3a 63 6f 6d 6d 69 74 5f 70 69 70 65 6c red:commit_pipel
0e40: 69 6e 65 28 29 0a 09 69 66 20 6e 6f 74 20 72 65 ine()..if not re
0e50: 73 20 74 68 65 6e 0a 09 09 6e 67 78 2e 6c 6f 67 s then...ngx.log
0e60: 28 6e 67 78 2e 45 52 52 2c 20 27 72 65 64 69 73 (ngx.ERR, 'redis
0e70: 20 74 72 61 6e 73 61 63 74 69 6f 6e 20 66 61 69 transaction fai
0e80: 6c 65 64 3a 20 27 2c 20 65 72 72 29 0a 09 09 6e led: ', err)...n
0e90: 67 78 2e 65 78 69 74 28 6e 67 78 2e 48 54 54 50 gx.exit(ngx.HTTP
0ea0: 5f 49 4e 54 45 52 4e 41 4c 5f 53 45 52 56 45 52 _INTERNAL_SERVER
0eb0: 5f 45 52 52 4f 52 29 0a 09 65 6e 64 0a 65 6e 64 _ERROR)..end.end
0ec0: 0a 0a 72 65 74 75 72 6e 20 5f 63 6f 75 6e 74 65 ..return _counte
0ed0: 72 0a r.