Megatest

Hex Artifact Content
Login

Artifact 59920959a9fd1b2d3054807db2c72d7c80ed732a:


0000: 0a 3b 3b 20 43 6f 70 79 72 69 67 68 74 20 32 30  .;; Copyright 20
0010: 30 36 2d 32 30 31 32 2c 20 4d 61 74 74 68 65 77  06-2012, Matthew
0020: 20 57 65 6c 6c 61 6e 64 2e 0a 3b 3b 20 0a 3b 3b   Welland..;; .;;
0030: 20 20 54 68 69 73 20 70 72 6f 67 72 61 6d 20 69    This program i
0040: 73 20 6d 61 64 65 20 61 76 61 69 6c 61 62 6c 65  s made available
0050: 20 75 6e 64 65 72 20 74 68 65 20 47 4e 55 20 47   under the GNU G
0060: 50 4c 20 76 65 72 73 69 6f 6e 20 32 2e 30 20 6f  PL version 2.0 o
0070: 72 0a 3b 3b 20 20 67 72 65 61 74 65 72 2e 20 53  r.;;  greater. S
0080: 65 65 20 74 68 65 20 61 63 63 6f 6d 70 61 6e 79  ee the accompany
0090: 69 6e 67 20 66 69 6c 65 20 43 4f 50 59 49 4e 47  ing file COPYING
00a0: 20 66 6f 72 20 64 65 74 61 69 6c 73 2e 0a 3b 3b   for details..;;
00b0: 20 0a 3b 3b 20 20 54 68 69 73 20 70 72 6f 67 72   .;;  This progr
00c0: 61 6d 20 69 73 20 64 69 73 74 72 69 62 75 74 65  am is distribute
00d0: 64 20 57 49 54 48 4f 55 54 20 41 4e 59 20 57 41  d WITHOUT ANY WA
00e0: 52 52 41 4e 54 59 3b 20 77 69 74 68 6f 75 74 20  RRANTY; without 
00f0: 65 76 65 6e 20 74 68 65 0a 3b 3b 20 20 69 6d 70  even the.;;  imp
0100: 6c 69 65 64 20 77 61 72 72 61 6e 74 79 20 6f 66  lied warranty of
0110: 20 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 54 59   MERCHANTABILITY
0120: 20 6f 72 20 46 49 54 4e 45 53 53 20 46 4f 52 20   or FITNESS FOR 
0130: 41 20 50 41 52 54 49 43 55 4c 41 52 0a 3b 3b 20  A PARTICULAR.;; 
0140: 20 50 55 52 50 4f 53 45 2e 0a 0a 28 72 65 71 75   PURPOSE...(requ
0150: 69 72 65 2d 65 78 74 65 6e 73 69 6f 6e 20 28 73  ire-extension (s
0160: 72 66 69 20 31 38 29 20 65 78 74 72 61 73 20 74  rfi 18) extras t
0170: 63 70 20 73 31 31 6e 29 0a 0a 28 75 73 65 20 73  cp s11n)..(use s
0180: 71 6c 69 74 65 33 20 73 72 66 69 2d 31 20 70 6f  qlite3 srfi-1 po
0190: 73 69 78 20 72 65 67 65 78 20 72 65 67 65 78 2d  six regex regex-
01a0: 63 61 73 65 20 73 72 66 69 2d 36 39 20 68 6f 73  case srfi-69 hos
01b0: 74 69 6e 66 6f 20 6d 64 35 20 6d 65 73 73 61 67  tinfo md5 messag
01c0: 65 2d 64 69 67 65 73 74 29 0a 28 69 6d 70 6f 72  e-digest).(impor
01d0: 74 20 28 70 72 65 66 69 78 20 73 71 6c 69 74 65  t (prefix sqlite
01e0: 33 20 73 71 6c 69 74 65 33 3a 29 29 0a 0a 28 75  3 sqlite3:))..(u
01f0: 73 65 20 73 70 69 66 66 79 20 75 72 69 2d 63 6f  se spiffy uri-co
0200: 6d 6d 6f 6e 20 69 6e 74 61 72 77 65 62 20 68 74  mmon intarweb ht
0210: 74 70 2d 63 6c 69 65 6e 74 20 73 70 69 66 66 79  tp-client spiffy
0220: 2d 72 65 71 75 65 73 74 2d 76 61 72 73 29 0a 0a  -request-vars)..
0230: 28 74 63 70 2d 62 75 66 66 65 72 2d 73 69 7a 65  (tcp-buffer-size
0240: 20 32 30 34 38 29 0a 0a 28 64 65 63 6c 61 72 65   2048)..(declare
0250: 20 28 75 6e 69 74 20 66 73 2d 74 72 61 6e 73 70   (unit fs-transp
0260: 6f 72 74 29 29 0a 0a 28 64 65 63 6c 61 72 65 20  ort))..(declare 
0270: 28 75 73 65 73 20 63 6f 6d 6d 6f 6e 29 29 0a 28  (uses common)).(
0280: 64 65 63 6c 61 72 65 20 28 75 73 65 73 20 64 62  declare (uses db
0290: 29 29 0a 28 64 65 63 6c 61 72 65 20 28 75 73 65  )).(declare (use
02a0: 73 20 74 65 73 74 73 29 29 0a 28 64 65 63 6c 61  s tests)).(decla
02b0: 72 65 20 28 75 73 65 73 20 74 61 73 6b 73 29 29  re (uses tasks))
02c0: 20 3b 3b 20 74 61 73 6b 73 20 61 72 65 20 77 68   ;; tasks are wh
02d0: 65 72 65 20 73 74 75 66 66 20 69 73 20 6d 61 69  ere stuff is mai
02e0: 6e 74 61 69 6e 65 64 20 61 62 6f 75 74 20 77 68  ntained about wh
02f0: 61 74 20 69 73 20 72 75 6e 6e 69 6e 67 2e 0a 0a  at is running...
0300: 28 69 6e 63 6c 75 64 65 20 22 63 6f 6d 6d 6f 6e  (include "common
0310: 5f 72 65 63 6f 72 64 73 2e 73 63 6d 22 29 0a 28  _records.scm").(
0320: 69 6e 63 6c 75 64 65 20 22 64 62 5f 72 65 63 6f  include "db_reco
0330: 72 64 73 2e 73 63 6d 22 29 0a 0a 0a 3b 3b 3d 3d  rds.scm")...;;==
0340: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
0350: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
0360: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
0370: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
0380: 3d 3d 3d 3d 0a 3b 3b 20 46 20 53 20 20 20 54 20  ====.;; F S   T 
0390: 52 20 41 20 4e 20 53 20 50 20 4f 20 52 20 54 20  R A N S P O R T 
03a0: 20 20 53 20 45 20 52 20 56 20 45 20 52 0a 3b 3b    S E R V E R.;;
03b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
03c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
03d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
03e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d  ================
03f0: 3d 3d 3d 3d 3d 3d 0a 0a 3b 3b 20 54 68 65 72 65  ======..;; There
0400: 20 69 73 20 6e 6f 20 22 73 65 72 76 65 72 22 20   is no "server" 
0410: 70 65 72 20 73 65 20 62 75 74 20 61 20 63 6f 6e  per se but a con
0420: 76 69 65 6e 63 65 20 72 6f 75 74 69 6e 65 20 74  vience routine t
0430: 6f 20 6d 61 6b 65 20 69 74 20 6e 6f 6e 0a 3b 3b  o make it non.;;
0440: 20 6e 65 63 65 73 73 61 72 79 20 74 6f 20 62 65   necessary to be
0450: 20 72 65 6f 70 65 6e 69 6e 67 20 74 68 65 20 64   reopening the d
0460: 62 20 6f 76 65 72 20 61 6e 64 20 6f 76 65 72 20  b over and over 
0470: 61 67 61 69 6e 2e 0a 3b 3b 0a 0a 28 64 65 66 69  again..;;..(defi
0480: 6e 65 20 28 66 73 3a 70 72 6f 63 65 73 73 2d 71  ne (fs:process-q
0490: 75 65 75 65 2d 69 74 65 6d 20 70 61 63 6b 65 74  ueue-item packet
04a0: 29 0a 20 20 28 69 66 20 28 6e 6f 74 20 2a 6d 65  ).  (if (not *me
04b0: 67 61 74 65 73 74 2d 64 62 2a 29 20 3b 3b 20 77  gatest-db*) ;; w
04c0: 65 20 77 69 6c 6c 20 72 65 71 75 69 72 65 20 74  e will require t
04d0: 68 61 74 20 28 73 65 74 75 70 2d 66 6f 72 2d 72  hat (setup-for-r
04e0: 75 6e 29 20 68 61 73 20 61 6c 72 65 61 64 79 20  un) has already 
04f0: 62 65 65 6e 20 63 61 6c 6c 65 64 0a 20 20 20 20  been called.    
0500: 20 20 28 73 65 74 21 20 2a 6d 65 67 61 74 65 73    (set! *megates
0510: 74 2d 64 62 2a 20 28 6f 70 65 6e 2d 64 62 29 29  t-db* (open-db))
0520: 29 0a 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74  ).  (debug:print
0530: 2d 69 6e 66 6f 20 31 31 20 2a 64 65 66 61 75 6c  -info 11 *defaul
0540: 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 66 73 3a  t-log-port* "fs:
0550: 70 72 6f 63 65 73 73 2d 71 75 65 75 65 2d 69 74  process-queue-it
0560: 65 6d 20 63 61 6c 6c 65 64 20 77 69 74 68 20 70  em called with p
0570: 61 63 6b 65 74 3d 22 20 70 61 63 6b 65 74 29 0a  acket=" packet).
0580: 20 20 28 64 62 3a 70 72 6f 63 65 73 73 2d 71 75    (db:process-qu
0590: 65 75 65 2d 69 74 65 6d 20 2a 6d 65 67 61 74 65  eue-item *megate
05a0: 73 74 2d 64 62 2a 20 70 61 63 6b 65 74 29 29 0a  st-db* packet)).
05b0: 20 20 20 20 20 20