0000: 2f 2a 0a 2a 2a 20 43 6f 70 79 72 69 67 68 74 20 /*.** Copyright
0010: 28 63 29 20 32 30 30 37 20 44 2e 20 52 69 63 68 (c) 2007 D. Rich
0020: 61 72 64 20 48 69 70 70 0a 2a 2a 0a 2a 2a 20 54 ard Hipp.**.** T
0030: 68 69 73 20 70 72 6f 67 72 61 6d 20 69 73 20 66 his program is f
0040: 72 65 65 20 73 6f 66 74 77 61 72 65 3b 20 79 6f ree software; yo
0050: 75 20 63 61 6e 20 72 65 64 69 73 74 72 69 62 75 u can redistribu
0060: 74 65 20 69 74 20 61 6e 64 2f 6f 72 0a 2a 2a 20 te it and/or.**
0070: 6d 6f 64 69 66 79 20 69 74 20 75 6e 64 65 72 20 modify it under
0080: 74 68 65 20 74 65 72 6d 73 20 6f 66 20 74 68 65 the terms of the
0090: 20 47 4e 55 20 47 65 6e 65 72 61 6c 20 50 75 62 GNU General Pub
00a0: 6c 69 63 0a 2a 2a 20 4c 69 63 65 6e 73 65 20 76 lic.** License v
00b0: 65 72 73 69 6f 6e 20 32 20 61 73 20 70 75 62 6c ersion 2 as publ
00c0: 69 73 68 65 64 20 62 79 20 74 68 65 20 46 72 65 ished by the Fre
00d0: 65 20 53 6f 66 74 77 61 72 65 20 46 6f 75 6e 64 e Software Found
00e0: 61 74 69 6f 6e 2e 0a 2a 2a 0a 2a 2a 20 54 68 69 ation..**.** Thi
00f0: 73 20 70 72 6f 67 72 61 6d 20 69 73 20 64 69 73 s program is dis
0100: 74 72 69 62 75 74 65 64 20 69 6e 20 74 68 65 20 tributed in the
0110: 68 6f 70 65 20 74 68 61 74 20 69 74 20 77 69 6c hope that it wil
0120: 6c 20 62 65 20 75 73 65 66 75 6c 2c 0a 2a 2a 20 l be useful,.**
0130: 62 75 74 20 57 49 54 48 4f 55 54 20 41 4e 59 20 but WITHOUT ANY
0140: 57 41 52 52 41 4e 54 59 3b 20 77 69 74 68 6f 75 WARRANTY; withou
0150: 74 20 65 76 65 6e 20 74 68 65 20 69 6d 70 6c 69 t even the impli
0160: 65 64 20 77 61 72 72 61 6e 74 79 20 6f 66 0a 2a ed warranty of.*
0170: 2a 20 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 54 * MERCHANTABILIT
0180: 59 20 6f 72 20 46 49 54 4e 45 53 53 20 46 4f 52 Y or FITNESS FOR
0190: 20 41 20 50 41 52 54 49 43 55 4c 41 52 20 50 55 A PARTICULAR PU
01a0: 52 50 4f 53 45 2e 20 20 53 65 65 20 74 68 65 20 RPOSE. See the
01b0: 47 4e 55 0a 2a 2a 20 47 65 6e 65 72 61 6c 20 50 GNU.** General P
01c0: 75 62 6c 69 63 20 4c 69 63 65 6e 73 65 20 66 6f ublic License fo
01d0: 72 20 6d 6f 72 65 20 64 65 74 61 69 6c 73 2e 0a r more details..
01e0: 2a 2a 20 0a 2a 2a 20 59 6f 75 20 73 68 6f 75 6c ** .** You shoul
01f0: 64 20 68 61 76 65 20 72 65 63 65 69 76 65 64 20 d have received
0200: 61 20 63 6f 70 79 20 6f 66 20 74 68 65 20 47 4e a copy of the GN
0210: 55 20 47 65 6e 65 72 61 6c 20 50 75 62 6c 69 63 U General Public
0220: 0a 2a 2a 20 4c 69 63 65 6e 73 65 20 61 6c 6f 6e .** License alon
0230: 67 20 77 69 74 68 20 74 68 69 73 20 6c 69 62 72 g with this libr
0240: 61 72 79 3b 20 69 66 20 6e 6f 74 2c 20 77 72 69 ary; if not, wri
0250: 74 65 20 74 6f 20 74 68 65 0a 2a 2a 20 46 72 65 te to the.** Fre
0260: 65 20 53 6f 66 74 77 61 72 65 20 46 6f 75 6e 64 e Software Found
0270: 61 74 69 6f 6e 2c 20 49 6e 63 2e 2c 20 35 39 20 ation, Inc., 59
0280: 54 65 6d 70 6c 65 20 50 6c 61 63 65 20 2d 20 53 Temple Place - S
0290: 75 69 74 65 20 33 33 30 2c 0a 2a 2a 20 42 6f 73 uite 330,.** Bos
02a0: 74 6f 6e 2c 20 4d 41 20 20 30 32 31 31 31 2d 31 ton, MA 02111-1
02b0: 33 30 37 2c 20 55 53 41 2e 0a 2a 2a 0a 2a 2a 20 307, USA..**.**
02c0: 41 75 74 68 6f 72 20 63 6f 6e 74 61 63 74 20 69 Author contact i
02d0: 6e 66 6f 72 6d 61 74 69 6f 6e 3a 0a 2a 2a 20 20 nformation:.**
02e0: 20 64 72 68 40 68 77 61 63 69 2e 63 6f 6d 0a 2a drh@hwaci.com.*
02f0: 2a 20 20 20 68 74 74 70 3a 2f 2f 77 77 77 2e 68 * http://www.h
0300: 77 61 63 69 2e 63 6f 6d 2f 64 72 68 2f 0a 2a 2a waci.com/drh/.**
0310: 0a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a .***************
0320: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0330: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0340: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0350: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0360: 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 66 69 6c 65 .**.** This file
0370: 20 63 6f 6e 74 61 69 6e 73 20 63 6f 64 65 20 74 contains code t
0380: 6f 20 69 6d 70 6c 65 6d 65 6e 74 20 74 68 65 20 o implement the
0390: 66 69 6c 65 20 74 72 61 6e 73 66 65 72 20 70 72 file transfer pr
03a0: 6f 74 6f 63 6f 6c 2e 0a 2a 2f 0a 23 69 6e 63 6c otocol..*/.#incl
03b0: 75 64 65 20 22 63 6f 6e 66 69 67 2e 68 22 0a 23 ude "config.h".#
03c0: 69 6e 63 6c 75 64 65 20 22 78 66 65 72 2e 68 22 include "xfer.h"
03d0: 0a 0a 2f 2a 0a 2a 2a 20 54 68 69 73 20 73 74 72 ../*.** This str
03e0: 75 63 74 75 72 65 20 68 6f 6c 64 73 20 69 6e 66 ucture holds inf
03f0: 6f 72 6d 61 74 69 6f 6e 20 61 62 6f 75 74 20 74 ormation about t
0400: 68 65 20 63 75 72 72 65 6e 74 20 73 74 61 74 65 he current state
0410: 20 6f 66 20 65 69 74 68 65 72 0a 2a 2a 20 61 20 of either.** a
0420: 63 6c 69 65 6e 74 20 6f 72 20 61 20 73 65 72 76 client or a serv
0430: 65 72 20 74 68 61 74 20 69 73 20 70 61 72 74 69 er that is parti
0440: 63 69 70 61 74 69 6e 67 20 69 6e 20 78 66 65 72 cipating in xfer
0450: 2e 0a 2a 2f 0a 74 79 70 65 64 65 66 20 73 74 72 ..*/.typedef str
0460: 75 63 74 20 58 66 65 72 20 58 66 65 72 3b 0a 73 uct Xfer Xfer;.s
0470: 74 72 75 63 74 20 58 66 65 72 20 7b 0a 20 20 42 truct Xfer {. B
0480: 6c 6f 62 20 2a 70 49 6e 3b 20 20 20 20 20 20 20 lob *pIn;
0490: 20 20 20 2f 2a 20 49 6e 70 75 74 20 74 65 78 74 /* Input text
04a0: 20 66 72 6f 6d 20 74 68 65 20 6f 74 68 65 72 20 from the other
04b0: 73 69 64 65 20 2a 2f 0a 20 20 42 6c 6f 62 20 2a side */. Blob *
04c0: 70 4f 75 74 3b 20 20 20 20 20 20 20 20 20 2f 2a pOut; /*
04d0: 20 43 6f 6d 70 6f 73 65 20 6f 75 72 20 72 65 70 Compose our rep
04e0: 6c 79 20 68 65 72 65 20 2a 2f 0a 20 20 42 6c 6f ly here */. Blo
04f0: 62 20 6c 69 6e 65 3b 20 20 20 20 20 20 20 20 20 b line;
0500: 20 2f 2a 20 54 68 65 20 63 75 72 72 65 6e 74 20 /* The current
0510: 6c 69 6e 65 20 6f 66 20 69 6e 70 75 74 20 2a 2f line of input */
0520: 0a 20 20 42 6c 6f 62 20 61 54 6f 6b 65 6e 5b 35 . Blob aToken[5
0530: 5d 3b 20 20 20 20 20 2f 2a 20 54 6f 6b 65 6e 69 ]; /* Tokeni
0540: 7a 65 64 20 76 65 72 73 69 6f 6e 20 6f 66 20 6c zed version of l
0550: 69 6e 65 20 2a 2f 0a 20 20 42 6c 6f 62 20 65 72 ine */. Blob er
0560: 72 3b 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 r; /*
0570: 45 72 72 6f 72 20 6d 65 73 73 61 67 65 20 74 65 Error message te
0580: 78 74 20 2a 2f 0a 20 20 69 6e 74 20 6e 54 6f 6b xt */. int nTok
0590: 65 6e 3b 20 20 20 20 20 20 20 20 20 2f 2a 20 4e en; /* N
05a0: 75 6d 62 65 72 20 6f 66 20 74 6f 6b 65 6e 73 20 umber of tokens
05b0: 69 6e 20 6c 69 6e 65 20 2a 2f 0a 20 20 69 6e 74 in line */. int
05c0: 20 6e 49 47 6f 74 53 65 6e 74 3b 20 20 20 20 20 nIGotSent;
05d0: 20 2f 2a 20 4e 75 6d 62 65 72 20 6f 66 20 22 69 /* Number of "i
05e0: 67 6f 74 22 20 6d 65 73 73 61 67 65 73 20 73 65 got" messages se
05f0: 6e 74 20 2a 2f 0a 20 20 69 6e 74 20 6e 47 69 6d nt */. int nGim
0600: 6d 65 53 65 6e 74 3b 20 20 20 20 20 2f 2a 20 4e meSent; /* N
0610: 75 6d 62 65 72 20 6f 66 20 67 69 6d 6d 65 20 6d umber of gimme m
0620: 65 73 73 61 67 65 73 20 73 65 6e 74 20 2a 2f 0a essages sent */.
0630: 20 20 69 6e 74 20 6e 46 69 6c 65 53 65 6e 74 3b int nFileSent;
0640: 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 20 /* Number
0650: 6f 66 20 66 69 6c 65 73 20 73 65 6e 74 20 2a 2f of files sent */
0660: 0a 20 20 69 6e 74 20 6e 44 65 6c 74 61 53 65 6e . int nDeltaSen
0670: 74 3b 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 t; /* Number
0680: 20 6f 66 20 64 65 6c 74 61 73 20 73 65 6e 74 20 of deltas sent
0690: 2a 2f 0a 20 20 69 6e 74 20 6e 46 69 6c 65 52 63 */. int nFileRc
06a0: 76 64 3b 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 vd; /* Numb
06b0: 65 72 20 6f 66 20 66 69 6c 65 73 20 72 65 63 65 er of files rece
06c0: 69 76 65 64 20 2a 2f 0a 20 20 69 6e 74 20 6e 44 ived */. int nD
06d0: 65 6c 74 61 52 63 76 64 3b 20 20 20 20 20 2f 2a eltaRcvd; /*
06e0: 20 4e 75 6d 62 65 72 20 6f 66 20 64 65 6c 74 61 Number of delta
06f0: 73 20 72 65 63 65 69 76 65 64 20 2a 2f 0a 20 20 s received */.
0700: 69 6e 74 20 6e 44 61 6e 67 6c 69 6e 67 46 69 6c int nDanglingFil
0710: 65 3b 20 20 2f 2a 20 4e 75 6d 62 65 72 20 6f 66 e; /* Number of
0720: 20 64 61 6e 67 6c 69 6e 67 20 64 65 6c 74 61 73 dangling deltas
0730: 20 72 65 63 65 69 76 65 64 20 2a 2f 0a 20 20 69 received */. i
0740: 6e 74 20 6d 78 53 65 6e 64 3b 20 20 20 20 20 20 nt mxSend;
0750: 20 20 20 2f 2a 20 53 74 6f 70 20 73 65 6e 64 69 /* Stop sendi
0760: 6e 67 20 22 66 69 6c 65 22 20 77 69 74 68 20 70 ng "file" with p
0770: 4f 75 74 20 72 65 61 63 68 65 73 20 74 68 69 73 Out reaches this
0780: 20 73 69 7a 65 20 2a 2f 0a 7d 3b 0a 0a 0a 2f 2a size */.};.../*
0790: 0a 2a 2a 20 54 68 65 20 69 6e 70 75 74 20 62 6c .** The input bl
07a0: 6f 62 20 63 6f 6e 74 61 69 6e 73 20 61 20 55 55 ob contains a UU
07b0: 49 44 2e 20 20 43 6f 6e 76 65 72 74 20 69 74 20 ID. Convert it
07c0: 69 6e 74 6f 20 61 20 72 65 63 6f 72 64 20 49 44 into a record ID
07d0: 2e 0a 2a 2a 20 43 72 65 61 74 65 20 61 20 70 68 ..** Create a ph
07e0: 61 6e 74 6f 6d 20 72 65 63 6f 72 64 20 69 66 20 antom record if
07f0: 6e 6f 20 70 72 69 6f 72 20 72 65 63 6f 72 64 20 no prior record
0800: 65 78 69 73 74 73 20 61 6e 64 0a 2a 2a 20 70 68 exists and.** ph
0810: 61 6e 74 6f 6d 69 7a 65 20 69 73 20 74 72 75 65 antomize is true
0820: 2e 0a 2a 2a 0a 2a 2a 20 43 6f 6d 70 61 72 65 20 ..**.** Compare
0830: 74 6f 20 75 75 69 64 5f 74 6f 5f 72 69 64 28 29 to uuid_to_rid()
0840: 2e 20 20 54 68 69 73 20 72 6f 75 74 69 6e 65 20 . This routine
0850: 74 61 6b 65 73 20 61 20 62 6c 6f 62 20 61 72 67 takes a blob arg
0860: 75 6d 65 6e 74 0a 2a 2a 20 61 6e 64 20 64 6f 65 ument.** and doe
0870: 73 20 6c 65 73 73 20 65 72 72 6f 72 20 63 68 65 s less error che
0880: 63 6b 69 6e 67 2e 0a 2a 2f 0a 73 74 61 74 69 63 cking..*/.static
0890: 20 69 6e 74 20 72 69 64 5f 66 72 6f 6d 5f 75 75 int rid_from_uu
08a0: 69 64 28 42 6c 6f 62 20 2a 70 55 75 69 64 2c 20 id(Blob *pUuid,
08b0: 69 6e 74 20 70 68 61 6e 74 6f 6d 69 7a 65 29 7b int phantomize){
08c0: 0a 20 20 69 6e 74 20 72 69 64 20 3d 20 64 62 5f . int rid = db_
08d0: 69 6e 74 28 30 2c 20 22 53 45 4c 45 43 54 20 72 int(0, "SELECT r
08e0: 69 64 20 46 52 4f 4d 20 62 6c 6f 62 20 57 48 45 id FROM blob WHE
08f0: 52 45 20 75 75 69 64 3d 27 25 62 27 22 2c 20 70 RE uuid='%b'", p
0900: 55 75 69 64 29 3b 0a 20 20 69 66 28 20 72 69 64 Uuid);. if( rid
0910: 3d 3d 30 20 26 26 20 70 68 61 6e 74 6f 6d 69 7a ==0 && phantomiz
0920: 65 20 29 7b 0a 20 20 20 20 72 69 64 20 3d 20 63 e ){. rid = c
0930: 6f 6e 74 65 6e 74 5f 70 75 74 28 30 2c 20 62 6c ontent_put(0, bl
0940: 6f 62 5f 73 74 72 28 70 55 75 69 64 29 2c 20 30 ob_str(pUuid), 0
0950: 29 3b 0a 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 );. }. return
0960: 72 69 64 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 rid;.}../*.** Re
0970: 6d 65 6d 62 65 72 20 74 68 61 74 20 74 68 65 20 member that the
0980: 6f 74 68 65 72 20 73 69 64 65 20 6f 66 20 74 68 other side of th
0990: 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 61 6c 72 e connection alr
09a0: 65 61 64 79 20 68 61 73 20 61 20 63 6f 70 79 0a eady has a copy.
09b0: 2a 2a 20 6f 66 20 74 68 65 20 66 69 6c 65 20 72 ** of the file r
09c0: 69 64 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f id..*/.static vo
09d0: 69 64 20 72 65 6d 6f 74 65 5f 68 61 73 28 69 6e id remote_has(in
09e0: 74 20 72 69 64 29 7b 0a 20 20 64 62 5f 6d 75 6c t rid){. db_mul
09f0: 74 69 5f 65 78 65 63 28 22 49 4e 53 45 52 54 20 ti_exec("INSERT
0a00: 4f 52 20 49 47 4e 4f 52 45 20 49 4e 54 4f 20 6f OR IGNORE INTO o
0a10: 6e 72 65 6d 6f 74 65 20 56 41 4c 55 45 53 28 25 nremote VALUES(%
0a20: 64 29 22 2c 20 72 69 64 29 3b 0a 7d 0a 0a 2f 2a d)", rid);.}../*
0a30: 0a 2a 2a 20 54 68 65 20 61 54 6f 6b 65 6e 5b 30 .** The aToken[0
0a40: 2e 2e 6e 54 6f 6b 65 6e 2d 31 5d 20 62 6c 6f 62 ..nToken-1] blob
0a50: 20 61 72 72 61 79 20 69 73 20 61 20 70 61 72 73 array is a pars
0a60: 65 20 6f 66 20 61 20 22 66 69 6c 65 22 20 6c 69 e of a "file" li
0a70: 6e 65 20 0a 2a 2a 20 6d 65 73 73 61 67 65 2e 20 ne .** message.
0a80: 20 54 68 69 73 20 72 6f 75 74 69 6e 65 20 66 69 This routine fi
0a90: 6e 69 73 68 65 73 20 70 61 72 73 69 6e 67 20 74 nishes parsing t
0aa0: 68 61 74 20 6d 65 73 73 61 67 65 20 61 6e 64 20 hat message and
0ab0: 64 6f 65 73 0a 2a 2a 20 61 20 72 65 63 6f 72 64 does.** a record
0ac0: 20 69 6e 73 65 72 74 20 6f 66 20 74 68 65 20 66 insert of the f
0ad0: 69 6c 65 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 20 66 ile..**.** The f
0ae0: 69 6c 65 20 6c 69 6e 65 20 69 73 20 69 6e 20 6f ile line is in o
0af0: 6e 65 20 6f 66 20 74 68 65 20 66 6f 6c 6c 6f 77 ne of the follow
0b00: 69 6e 67 20 74 77 6f 20 66 6f 72 6d 73 3a 0a 2a ing two forms:.*
0b10: 2a 0a 2a 2a 20 20 20 20 20 20 66 69 6c 65 20 55 *.** file U
0b20: 55 49 44 20 53 49 5a 45 20 5c 6e 20 43 4f 4e 54 UID SIZE \n CONT
0b30: 45 4e 54 0a 2a 2a 20 20 20 20 20 20 66 69 6c 65 ENT.** file
0b40: 20 55 55 49 44 20 44 45 4c 54 41 53 52 43 20 53 UUID DELTASRC S
0b50: 49 5a 45 20 5c 6e 20 43 4f 4e 54 45 4e 54 0a 2a IZE \n CONTENT.*
0b60: 2a 0a 2a 2a 20 54 68 65 20 63 6f 6e 74 65 6e 74 *.** The content
0b70: 20 69 73 20 53 49 5a 45 20 62 79 74 65 73 20 69 is SIZE bytes i
0b80: 6d 6d 65 64 69 61 74 65 6c 79 20 66 6f 6c 6c 6f mmediately follo
0b90: 77 69 6e 67 20 74 68 65 20 6e 65 77 6c 69 6e 65 wing the newline
0ba0: 2e 0a 2a 2a 20 49 66 20 44 45 4c 54 41 53 52 43 ..** If DELTASRC
0bb0: 20 65 78 69 73 74 73 2c 20 74 68 65 6e 20 74 68 exists, then th
0bc0: 65 20 43 4f 4e 54 45 4e 54 20 69 73 20 61 20 64 e CONTENT is a d
0bd0: 65 6c 74 61 20 61 67 61 69 6e 73 74 20 74 68 65 elta against the
0be0: 0a 2a 2a 20 63 6f 6e 74 65 6e 74 20 6f 66 20 44 .** content of D
0bf0: 45 4c 54 41 53 52 43 2e 0a 2a 2a 0a 2a 2a 20 49 ELTASRC..**.** I
0c00: 66 20 61 6e 79 20 65 72 72 6f 72 20 6f 63 63 75 f any error occu
0c10: 72 73 2c 20 77 72 69 74 65 20 61 20 6d 65 73 73 rs, write a mess
0c20: 61 67 65 20 69 6e 74 6f 20 70 45 72 72 20 77 68 age into pErr wh
0c30: 69 63 68 20 68 61 73 20 61 6c 72 65 61 64 79 0a ich has already.
0c40: 2a 2a 20 62 65 20 69 6e 69 74 69 61 6c 69 7a 65 ** be initialize
0c50: 64 20 74 6f 20 61 6e 20 65 6d 70 74 79 20 73 74 d to an empty st
0c60: 72 69 6e 67 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 ring..*/.static
0c70: 76 6f 69 64 20 78 66 65 72 5f 61 63 63 65 70 74 void xfer_accept
0c80: 5f 66 69 6c 65 28 58 66 65 72 20 2a 70 58 66 65 _file(Xfer *pXfe
0c90: 72 29 7b 0a 20 20 69 6e 74 20 6e 3b 0a 20 20 69 r){. int n;. i
0ca0: 6e 74 20 72 69 64 3b 0a 20 20 69 6e 74 20 73 72 nt rid;. int sr
0cb0: 63 69 64 20 3d 20 30 3b 0a 20 20 42 6c 6f 62 20 cid = 0;. Blob
0cc0: 63 6f 6e 74 65 6e 74 2c 20 68 61 73 68 3b 0a 20 content, hash;.
0cd0: 20 0a 20 20 69 66 28 20 70 58 66 65 72 2d 3e 6e . if( pXfer->n
0ce0: 54 6f 6b 65 6e 3c 33 20 0a 20 20 20 7c 7c 20 70 Token<3 . || p
0cf0: 58 66 65 72 2d 3e 6e 54 6f 6b 65 6e 3e 34 0a 20 Xfer->nToken>4.
0d00: 20 20 7c 7c 20 21 62 6c 6f 62 5f 69 73 5f 75 75 || !blob_is_uu
0d10: 69 64 28 26 70 58 66 65 72 2d 3e 61 54 6f 6b 65 id(&pXfer->aToke
0d20: 6e 5b 31 5d 29 0a 20 20 20 7c 7c 20 21 62 6c 6f n[1]). || !blo
0d30: 62 5f 69 73 5f 69 6e 74 28 26 70 58 66 65 72 2d b_is_int(&pXfer-
0d40: 3e 61 54 6f 6b 65 6e 5b 70 58 66 65 72 2d 3e 6e >aToken[pXfer->n
0d50: 54 6f 6b 65 6e 2d 31 5d 2c 20 26 6e 29 0a 20 20 Token-1], &n).
0d60: 20 7c 7c 20 6e 3c 30 0a 20 20 20 7c 7c 20 28 70 || n<0. || (p
0d70: 58 66 65 72 2d 3e 6e 54 6f 6b 65 6e 3d 3d 34 20 Xfer->nToken==4
0d80: 26 26 20 21 62 6c 6f 62 5f 69 73 5f 75 75 69 64 && !blob_is_uuid
0d90: 28 26 70 58 66 65 72 2d 3e 61 54 6f 6b 65 6e 5b (&pXfer->aToken[
0da0: 32 5d 29 29 0a 20 20 29 7b 0a 20 20 20 20 62 6c 2])). ){. bl
0db0: 6f 62 5f 61 70 70 65 6e 64 66 28 26 70 58 66 65 ob_appendf(&pXfe
0dc0: 72 2d 3e 65 72 72 2c 20 22 6d 61 6c 66 6f 72 6d r->err, "malform
0dd0: 65 64 20 66 69 6c 65 20 6c 69 6e 65 22 29 3b 0a ed file line");.
0de0: 20 20 20 20 72 65 74 75 72 6e 3b 0a 20 20 7d 0a return;. }.
0df0: 20 20 62 6c 6f 62 5f 7a 65 72 6f 28 26 63 6f 6e blob_zero(&con
0e00: 74 65 6e 74 29 3b 0a 20 20 62 6c 6f 62 5f 7a 65 tent);. blob_ze
0e10: 72 6f 28 26 68 61 73 68 29 3b 0a 20 20 62 6c 6f ro(&hash);. blo
0e20: 62 5f 65 78 74 72 61 63 74 28 70 58 66 65 72 2d b_extract(pXfer-
0e30: 3e 70 49 6e 2c 20 6e 2c 20 26 63 6f 6e 74 65 6e >pIn, n, &conten
0e40: 74 29 3b 0a 20 20 69 66 28 20 64 62 5f 65 78 69 t);. if( db_exi
0e50: 73 74 73 28 22 53 45 4c 45 43 54 20 31 20 46 52 sts("SELECT 1 FR
0e60: 4f 4d 20 73 68 75 6e 20 57 48 45 52 45 20 75 75 OM shun WHERE uu
0e70: 69 64 3d 25 42 22 2c 20 26 70 58 66 65 72 2d 3e id=%B", &pXfer->
0e80: 61 54 6f 6b 65 6e 5b 31 5d 29 20 29 7b 0a 20 20 aToken[1]) ){.
0e90: 20 20 2f 2a 20 49 67 6e 6f 72 65 20 66 69 6c 65 /* Ignore file
0ea0: 73 20 74 68 61 74 20 68 61 76 65 20 62 65 65 6e s that have been
0eb0: 20 73 68 75 6e 6e 65 64 20 2a 2f 0a 20 20 20 20 shunned */.
0ec0: 72 65 74 75 72 6e 3b 0a 20 20 7d 0a 20 20 69 66 return;. }. if
0ed0: 28 20 70 58 66 65 72 2d 3e 6e 54 6f 6b 65 6e 3d ( pXfer->nToken=
0ee0: 3d 34 20 29 7b 0a 20 20 20 20 42 6c 6f 62 20 73 =4 ){. Blob s
0ef0: 72 63 3b 0a 20 20 20 20 73 72 63 69 64 20 3d 20 rc;. srcid =
0f00: 72 69 64 5f 66 72 6f 6d 5f 75 75 69 64 28 26 70 rid_from_uuid(&p
0f10: 58 66 65 72 2d 3e 61 54 6f 6b 65 6e 5b 32 5d 2c Xfer->aToken[2],
0f20: 20 31 29 3b 0a 20 20 20 20 69 66 28 20 63 6f 6e 1);. if( con
0f30: 74 65 6e 74 5f 67 65 74 28 73 72 63 69 64 2c 20 tent_get(srcid,
0f40: 26 73 72 63 29 3d 3d 30 20 29 7b 0a 20 20 20 20 &src)==0 ){.
0f50: 20 20 63 6f 6e 74 65 6e 74 5f 70 75 74 28 26 63 content_put(&c
0f60: 6f 6e 74 65 6e 74 2c 20 62 6c 6f 62 5f 73 74 72 ontent, blob_str
0f70: 28 26 70 58 66 65 72 2d 3e 61 54 6f 6b 65 6e 5b (&pXfer->aToken[
0f80: 31 5d 29 2c 20 73 72 63 69 64 29 3b 0a 20 20 20 1]), srcid);.
0f90: 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 28 blob_appendf(
0fa0: 70 58 66 65 72 2d 3e 70 4f 75 74 2c 20 22 67 69 pXfer->pOut, "gi
0fb0: 6d 6d 65 20 25 62 5c 6e 22 2c 20 26 70 58 66 65 mme %b\n", &pXfe
0fc0: 72 2d 3e 61 54 6f 6b 65 6e 5b 32 5d 29 3b 0a 20 r->aToken[2]);.
0fd0: 20 20 20 20 20 70 58 66 65 72 2d 3e 6e 47 69 6d pXfer->nGim
0fe0: 6d 65 53 65 6e 74 2b 2b 3b 0a 20 20 20 20 20 20 meSent++;.
0ff0: 70 58 66 65 72 2d 3e 6e 44 61 6e 67 6c 69 6e 67 pXfer->nDangling
1000: 46 69 6c 65 2b 2b 3b 0a 20 20 20 20 20 20 72 65 File++;. re
1010: 74 75 72 6e 3b 0a 20 20 20 20 7d 0a 20 20 20 20 turn;. }.
1020: 70 58 66 65 72 2d 3e 6e 44 65 6c 74 61 52 63 76 pXfer->nDeltaRcv
1030: 64 2b 2b 3b 0a 20 20 20 20 62 6c 6f 62 5f 64 65 d++;. blob_de
1040: 6c 74 61 5f 61 70 70 6c 79 28 26 73 72 63 2c 20 lta_apply(&src,
1050: 26 63 6f 6e 74 65 6e 74 2c 20 26 63 6f 6e 74 65 &content, &conte
1060: 6e 74 29 3b 0a 20 20 20 20 62 6c 6f 62 5f 72 65 nt);. blob_re
1070: 73 65 74 28 26 73 72 63 29 3b 0a 20 20 7d 65 6c set(&src);. }el
1080: 73 65 7b 0a 20 20 20 20 70 58 66 65 72 2d 3e 6e se{. pXfer->n
1090: 46 69 6c 65 52 63 76 64 2b 2b 3b 0a 20 20 7d 0a FileRcvd++;. }.
10a0: 20 20 73 68 61 31 73 75 6d 5f 62 6c 6f 62 28 26 sha1sum_blob(&
10b0: 63 6f 6e 74 65 6e 74 2c 20 26 68 61 73 68 29 3b content, &hash);
10c0: 0a 20 20 69 66 28 20 21 62 6c 6f 62 5f 65 71 5f . if( !blob_eq_
10d0: 73 74 72 28 26 70 58 66 65 72 2d 3e 61 54 6f 6b str(&pXfer->aTok
10e0: 65 6e 5b 31 5d 2c 20 62 6c 6f 62 5f 73 74 72 28 en[1], blob_str(
10f0: 26 68 61 73 68 29 2c 20 2d 31 29 20 29 7b 0a 20 &hash), -1) ){.
1100: 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 28 blob_appendf(
1110: 26 70 58 66 65 72 2d 3e 65 72 72 2c 20 22 63 6f &pXfer->err, "co
1120: 6e 74 65 6e 74 20 64 6f 65 73 20 6e 6f 74 20 6d ntent does not m
1130: 61 74 63 68 20 73 68 61 31 20 68 61 73 68 22 29 atch sha1 hash")
1140: 3b 0a 20 20 7d 0a 20 20 62 6c 6f 62 5f 72 65 73 ;. }. blob_res
1150: 65 74 28 26 68 61 73 68 29 3b 0a 20 20 72 69 64 et(&hash);. rid
1160: 20 3d 20 63 6f 6e 74 65 6e 74 5f 70 75 74 28 26 = content_put(&
1170: 63 6f 6e 74 65 6e 74 2c 20 30 2c 20 30 29 3b 0a content, 0, 0);.
1180: 20 20 69 66 28 20 72 69 64 3d 3d 30 20 29 7b 0a if( rid==0 ){.
1190: 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 blob_appendf
11a0: 28 26 70 58 66 65 72 2d 3e 65 72 72 2c 20 22 25 (&pXfer->err, "%
11b0: 73 22 2c 20 67 2e 7a 45 72 72 4d 73 67 29 3b 0a s", g.zErrMsg);.
11c0: 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 6d 61 6e }else{. man
11d0: 69 66 65 73 74 5f 63 72 6f 73 73 6c 69 6e 6b 28 ifest_crosslink(
11e0: 72 69 64 2c 20 26 63 6f 6e 74 65 6e 74 29 3b 0a rid, &content);.
11f0: 20 20 7d 0a 20 20 72 65 6d 6f 74 65 5f 68 61 73 }. remote_has
1200: 28 72 69 64 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 (rid);.}../*.**
1210: 54 72 79 20 74 6f 20 73 65 6e 64 20 61 20 66 69 Try to send a fi
1220: 6c 65 20 61 73 20 61 20 64 65 6c 74 61 20 61 67 le as a delta ag
1230: 61 69 6e 73 74 20 69 74 73 20 70 61 72 65 6e 74 ainst its parent
1240: 2e 0a 2a 2a 20 49 66 20 73 75 63 63 65 73 73 66 ..** If successf
1250: 75 6c 2c 20 72 65 74 75 72 6e 20 74 68 65 20 6e ul, return the n
1260: 75 6d 62 65 72 20 6f 66 20 62 79 74 65 73 20 69 umber of bytes i
1270: 6e 20 74 68 65 20 64 65 6c 74 61 2e 0a 2a 2a 20 n the delta..**
1280: 49 66 20 77 65 20 63 61 6e 6e 6f 74 20 67 65 6e If we cannot gen
1290: 65 72 61 74 65 20 61 6e 20 61 70 70 72 6f 70 72 erate an appropr
12a0: 69 61 74 65 20 64 65 6c 74 61 2c 20 74 68 65 6e iate delta, then
12b0: 20 73 65 6e 64 0a 2a 2a 20 6e 6f 74 68 69 6e 67 send.** nothing
12c0: 20 61 6e 64 20 72 65 74 75 72 6e 20 7a 65 72 6f and return zero
12d0: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74 20 ..*/.static int
12e0: 73 65 6e 64 5f 64 65 6c 74 61 5f 70 61 72 65 6e send_delta_paren
12f0: 74 28 0a 20 20 58 66 65 72 20 2a 70 58 66 65 72 t(. Xfer *pXfer
1300: 2c 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 , /*
1310: 54 68 65 20 74 72 61 6e 73 66 65 72 20 63 6f 6e The transfer con
1320: 74 65 78 74 20 2a 2f 0a 20 20 69 6e 74 20 72 69 text */. int ri
1330: 64 2c 20 20 20 20 20 20 20 20 20 20 20 20 20 20 d,
1340: 20 20 2f 2a 20 72 65 63 6f 72 64 20 69 64 20 6f /* record id o
1350: 66 20 74 68 65 20 66 69 6c 65 20 74 6f 20 73 65 f the file to se
1360: 6e 64 20 2a 2f 0a 20 20 42 6c 6f 62 20 2a 70 43 nd */. Blob *pC
1370: 6f 6e 74 65 6e 74 2c 20 20 20 20 20 20 20 20 20 ontent,
1380: 2f 2a 20 54 68 65 20 63 6f 6e 74 65 6e 74 20 6f /* The content o
1390: 66 20 74 68 65 20 66 69 6c 65 20 74 6f 20 73 65 f the file to se
13a0: 6e 64 20 2a 2f 0a 20 20 42 6c 6f 62 20 2a 70 55 nd */. Blob *pU
13b0: 75 69 64 20 20 20 20 20 20 20 20 20 20 20 20 20 uid
13c0: 2f 2a 20 54 68 65 20 55 55 49 44 20 6f 66 20 74 /* The UUID of t
13d0: 68 65 20 66 69 6c 65 20 74 6f 20 73 65 6e 64 20 he file to send
13e0: 2a 2f 0a 29 7b 0a 20 20 73 74 61 74 69 63 20 63 */.){. static c
13f0: 6f 6e 73 74 20 63 68 61 72 20 2a 61 7a 51 75 65 onst char *azQue
1400: 72 79 5b 5d 20 3d 20 7b 0a 20 20 20 20 22 53 45 ry[] = {. "SE
1410: 4c 45 43 54 20 70 69 64 20 46 52 4f 4d 20 70 6c LECT pid FROM pl
1420: 69 6e 6b 20 78 22 0a 20 20 20 20 22 20 57 48 45 ink x". " WHE
1430: 52 45 20 63 69 64 3d 25 64 22 0a 20 20 20 20 22 RE cid=%d". "
1440: 20 20 20 41 4e 44 20 4e 4f 54 20 45 58 49 53 54 AND NOT EXIST
1450: 53 28 53 45 4c 45 43 54 20 31 20 46 52 4f 4d 20 S(SELECT 1 FROM
1460: 70 68 61 6e 74 6f 6d 20 57 48 45 52 45 20 72 69 phantom WHERE ri
1470: 64 3d 70 69 64 29 22 0a 20 20 20 20 22 20 20 20 d=pid)". "
1480: 41 4e 44 20 4e 4f 54 20 45 58 49 53 54 53 28 53 AND NOT EXISTS(S
1490: 45 4c 45 43 54 20 31 20 46 52 4f 4d 20 70 6c 69 ELECT 1 FROM pli
14a0: 6e 6b 20 79 22 0a 20 20 20 20 20 20 20 20 20 20 nk y".
14b0: 20 20 20 20 20 20 20 20 20 20 20 20 22 20 57 48 " WH
14c0: 45 52 45 20 79 2e 70 69 64 3d 78 2e 63 69 64 20 ERE y.pid=x.cid
14d0: 41 4e 44 20 79 2e 63 69 64 3d 78 2e 70 69 64 29 AND y.cid=x.pid)
14e0: 22 2c 0a 0a 20 20 20 20 22 53 45 4c 45 43 54 20 ",.. "SELECT
14f0: 70 69 64 20 46 52 4f 4d 20 6d 6c 69 6e 6b 20 78 pid FROM mlink x
1500: 22 0a 20 20 20 20 22 20 57 48 45 52 45 20 66 69 ". " WHERE fi
1510: 64 3d 25 64 22 0a 20 20 20 20 22 20 20 20 41 4e d=%d". " AN
1520: 44 20 4e 4f 54 20 45 58 49 53 54 53 28 53 45 4c D NOT EXISTS(SEL
1530: 45 43 54 20 31 20 46 52 4f 4d 20 70 68 61 6e 74 ECT 1 FROM phant
1540: 6f 6d 20 57 48 45 52 45 20 72 69 64 3d 70 69 64 om WHERE rid=pid
1550: 29 22 0a 20 20 20 20 22 20 20 20 41 4e 44 20 4e )". " AND N
1560: 4f 54 20 45 58 49 53 54 53 28 53 45 4c 45 43 54 OT EXISTS(SELECT
1570: 20 31 20 46 52 4f 4d 20 6d 6c 69 6e 6b 20 79 22 1 FROM mlink y"
1580: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
1590: 20 20 20 20 20 20 22 20 20 57 48 45 52 45 20 79 " WHERE y
15a0: 2e 70 69 64 3d 78 2e 66 69 64 20 41 4e 44 20 79 .pid=x.fid AND y
15b0: 2e 66 69 64 3d 78 2e 70 69 64 29 22 0a 20 20 7d .fid=x.pid)". }
15c0: 3b 0a 20 20 69 6e 74 20 69 3b 0a 20 20 42 6c 6f ;. int i;. Blo
15d0: 62 20 73 72 63 2c 20 64 65 6c 74 61 3b 0a 20 20 b src, delta;.
15e0: 69 6e 74 20 73 69 7a 65 20 3d 20 30 3b 0a 20 20 int size = 0;.
15f0: 69 6e 74 20 73 72 63 49 64 20 3d 20 30 3b 0a 0a int srcId = 0;..
1600: 20 20 66 6f 72 28 69 3d 30 3b 20 73 72 63 49 64 for(i=0; srcId
1610: 3d 3d 30 20 26 26 20 69 3c 63 6f 75 6e 74 28 61 ==0 && i<count(a
1620: 7a 51 75 65 72 79 29 3b 20 69 2b 2b 29 7b 0a 20 zQuery); i++){.
1630: 20 20 20 73 72 63 49 64 20 3d 20 64 62 5f 69 6e srcId = db_in
1640: 74 28 30 2c 20 61 7a 51 75 65 72 79 5b 69 5d 2c t(0, azQuery[i],
1650: 20 72 69 64 29 3b 0a 20 20 7d 0a 20 20 69 66 28 rid);. }. if(
1660: 20 73 72 63 49 64 3e 30 20 26 26 20 63 6f 6e 74 srcId>0 && cont
1670: 65 6e 74 5f 67 65 74 28 73 72 63 49 64 2c 20 26 ent_get(srcId, &
1680: 73 72 63 29 20 29 7b 0a 20 20 20 20 63 68 61 72 src) ){. char
1690: 20 2a 7a 55 75 69 64 20 3d 20 64 62 5f 74 65 78 *zUuid = db_tex
16a0: 74 28 30 2c 20 22 53 45 4c 45 43 54 20 75 75 69 t(0, "SELECT uui
16b0: 64 20 46 52 4f 4d 20 62 6c 6f 62 20 57 48 45 52 d FROM blob WHER
16c0: 45 20 72 69 64 3d 25 64 22 2c 20 73 72 63 49 64 E rid=%d", srcId
16d0: 29 3b 0a 20 20 20 20 62 6c 6f 62 5f 64 65 6c 74 );. blob_delt
16e0: 61 5f 63 72 65 61 74 65 28 26 73 72 63 2c 20 70 a_create(&src, p
16f0: 43 6f 6e 74 65 6e 74 2c 20 26 64 65 6c 74 61 29 Content, &delta)
1700: 3b 0a 20 20 20 20 73 69 7a 65 20 3d 20 62 6c 6f ;. size = blo
1710: 62 5f 73 69 7a 65 28 26 64 65 6c 74 61 29 3b 0a b_size(&delta);.
1720: 20 20 20 20 69 66 28 20 73 69 7a 65 3e 3d 62 6c if( size>=bl
1730: 6f 62 5f 73 69 7a 65 28 70 43 6f 6e 74 65 6e 74 ob_size(pContent
1740: 29 2d 35 30 20 29 7b 0a 20 20 20 20 20 20 73 69 )-50 ){. si
1750: 7a 65 20 3d 20 30 3b 0a 20 20 20 20 7d 65 6c 73 ze = 0;. }els
1760: 65 7b 0a 20 20 20 20 20 20 62 6c 6f 62 5f 61 70 e{. blob_ap
1770: 70 65 6e 64 66 28 70 58 66 65 72 2d 3e 70 4f 75 pendf(pXfer->pOu
1780: 74 2c 20 22 66 69 6c 65 20 25 62 20 25 73 20 25 t, "file %b %s %
1790: 64 5c 6e 22 2c 20 70 55 75 69 64 2c 20 7a 55 75 d\n", pUuid, zUu
17a0: 69 64 2c 20 73 69 7a 65 29 3b 0a 20 20 20 20 20 id, size);.
17b0: 20 62 6c 6f 62 5f 61 70 70 65 6e 64 28 70 58 66 blob_append(pXf
17c0: 65 72 2d 3e 70 4f 75 74 2c 20 62 6c 6f 62 5f 62 er->pOut, blob_b
17d0: 75 66 66 65 72 28 26 64 65 6c 74 61 29 2c 20 73 uffer(&delta), s
17e0: 69 7a 65 29 3b 0a 20 20 20 20 20 20 2f 2a 20 62 ize);. /* b
17f0: 6c 6f 62 5f 61 70 70 65 6e 64 66 28 70 58 66 65 lob_appendf(pXfe
1800: 72 2d 3e 70 4f 75 74 2c 20 22 5c 6e 22 2c 20 31 r->pOut, "\n", 1
1810: 29 3b 20 2a 2f 0a 20 20 20 20 7d 0a 20 20 20 20 ); */. }.
1820: 62 6c 6f 62 5f 72 65 73 65 74 28 26 64 65 6c 74 blob_reset(&delt
1830: 61 29 3b 0a 20 20 20 20 66 72 65 65 28 7a 55 75 a);. free(zUu
1840: 69 64 29 3b 0a 20 20 20 20 62 6c 6f 62 5f 72 65 id);. blob_re
1850: 73 65 74 28 26 73 72 63 29 3b 0a 20 20 7d 0a 20 set(&src);. }.
1860: 20 72 65 74 75 72 6e 20 73 69 7a 65 3b 0a 7d 0a return size;.}.
1870: 0a 2f 2a 0a 2a 2a 20 54 72 79 20 74 6f 20 73 65 ./*.** Try to se
1880: 6e 64 20 61 20 66 69 6c 65 20 61 73 20 61 20 6e nd a file as a n
1890: 61 74 69 76 65 20 64 65 6c 74 61 2e 20 20 0a 2a ative delta. .*
18a0: 2a 20 49 66 20 73 75 63 63 65 73 73 66 75 6c 2c * If successful,
18b0: 20 72 65 74 75 72 6e 20 74 68 65 20 6e 75 6d 62 return the numb
18c0: 65 72 20 6f 66 20 62 79 74 65 73 20 69 6e 20 74 er of bytes in t
18d0: 68 65 20 64 65 6c 74 61 2e 0a 2a 2a 20 49 66 20 he delta..** If
18e0: 77 65 20 63 61 6e 6e 6f 74 20 67 65 6e 65 72 61 we cannot genera
18f0: 74 65 20 61 6e 20 61 70 70 72 6f 70 72 69 61 74 te an appropriat
1900: 65 20 64 65 6c 74 61 2c 20 74 68 65 6e 20 73 65 e delta, then se
1910: 6e 64 0a 2a 2a 20 6e 6f 74 68 69 6e 67 20 61 6e nd.** nothing an
1920: 64 20 72 65 74 75 72 6e 20 7a 65 72 6f 2e 0a 2a d return zero..*
1930: 2f 0a 73 74 61 74 69 63 20 69 6e 74 20 73 65 6e /.static int sen
1940: 64 5f 64 65 6c 74 61 5f 6e 61 74 69 76 65 28 0a d_delta_native(.
1950: 20 20 58 66 65 72 20 2a 70 58 66 65 72 2c 20 20 Xfer *pXfer,
1960: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 54 68 65 /* The
1970: 20 74 72 61 6e 73 66 65 72 20 63 6f 6e 74 65 78 transfer contex
1980: 74 20 2a 2f 0a 20 20 69 6e 74 20 72 69 64 2c 20 t */. int rid,
1990: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f /
19a0: 2a 20 72 65 63 6f 72 64 20 69 64 20 6f 66 20 74 * record id of t
19b0: 68 65 20 66 69 6c 65 20 74 6f 20 73 65 6e 64 20 he file to send
19c0: 2a 2f 0a 20 20 42 6c 6f 62 20 2a 70 55 75 69 64 */. Blob *pUuid
19d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
19e0: 54 68 65 20 55 55 49 44 20 6f 66 20 74 68 65 20 The UUID of the
19f0: 66 69 6c 65 20 74 6f 20 73 65 6e 64 20 2a 2f 0a file to send */.
1a00: 29 7b 0a 20 20 42 6c 6f 62 20 73 72 63 2c 20 64 ){. Blob src, d
1a10: 65 6c 74 61 3b 0a 20 20 69 6e 74 20 73 69 7a 65 elta;. int size
1a20: 20 3d 20 30 3b 0a 20 20 69 6e 74 20 73 72 63 49 = 0;. int srcI
1a30: 64 3b 0a 0a 20 20 73 72 63 49 64 20 3d 20 64 62 d;.. srcId = db
1a40: 5f 69 6e 74 28 30 2c 20 22 53 45 4c 45 43 54 20 _int(0, "SELECT
1a50: 73 72 63 69 64 20 46 52 4f 4d 20 64 65 6c 74 61 srcid FROM delta
1a60: 20 57 48 45 52 45 20 72 69 64 3d 25 64 22 2c 20 WHERE rid=%d",
1a70: 72 69 64 29 3b 0a 20 20 69 66 28 20 73 72 63 49 rid);. if( srcI
1a80: 64 3e 30 20 29 7b 0a 20 20 20 20 62 6c 6f 62 5f d>0 ){. blob_
1a90: 7a 65 72 6f 28 26 64 65 6c 74 61 29 3b 0a 20 20 zero(&delta);.
1aa0: 20 20 64 62 5f 62 6c 6f 62 28 26 64 65 6c 74 61 db_blob(&delta
1ab0: 2c 20 22 53 45 4c 45 43 54 20 63 6f 6e 74 65 6e , "SELECT conten
1ac0: 74 20 46 52 4f 4d 20 62 6c 6f 62 20 57 48 45 52 t FROM blob WHER
1ad0: 45 20 72 69 64 3d 25 64 22 2c 20 72 69 64 29 3b E rid=%d", rid);
1ae0: 0a 20 20 20 20 62 6c 6f 62 5f 75 6e 63 6f 6d 70 . blob_uncomp
1af0: 72 65 73 73 28 26 64 65 6c 74 61 2c 20 26 64 65 ress(&delta, &de
1b00: 6c 74 61 29 3b 0a 20 20 20 20 62 6c 6f 62 5f 7a lta);. blob_z
1b10: 65 72 6f 28 26 73 72 63 29 3b 0a 20 20 20 20 64 ero(&src);. d
1b20: 62 5f 62 6c 6f 62 28 26 73 72 63 2c 20 22 53 45 b_blob(&src, "SE
1b30: 4c 45 43 54 20 75 75 69 64 20 46 52 4f 4d 20 62 LECT uuid FROM b
1b40: 6c 6f 62 20 57 48 45 52 45 20 72 69 64 3d 25 64 lob WHERE rid=%d
1b50: 22 2c 20 73 72 63 49 64 29 3b 0a 20 20 20 20 62 ", srcId);. b
1b60: 6c 6f 62 5f 61 70 70 65 6e 64 66 28 70 58 66 65 lob_appendf(pXfe
1b70: 72 2d 3e 70 4f 75 74 2c 20 22 66 69 6c 65 20 25 r->pOut, "file %
1b80: 62 20 25 62 20 25 64 5c 6e 22 2c 0a 20 20 20 20 b %b %d\n",.
1b90: 20 20 20 20 20 20 20 20 20 20 20 20 70 55 75 69 pUui
1ba0: 64 2c 20 26 73 72 63 2c 20 62 6c 6f 62 5f 73 69 d, &src, blob_si
1bb0: 7a 65 28 26 64 65 6c 74 61 29 29 3b 0a 20 20 20 ze(&delta));.
1bc0: 20 62 6c 6f 62 5f 61 70 70 65 6e 64 28 70 58 66 blob_append(pXf
1bd0: 65 72 2d 3e 70 4f 75 74 2c 20 62 6c 6f 62 5f 62 er->pOut, blob_b
1be0: 75 66 66 65 72 28 26 64 65 6c 74 61 29 2c 20 62 uffer(&delta), b
1bf0: 6c 6f 62 5f 73 69 7a 65 28 26 64 65 6c 74 61 29 lob_size(&delta)
1c00: 29 3b 0a 20 20 20 20 73 69 7a 65 20 3d 20 62 6c );. size = bl
1c10: 6f 62 5f 73 69 7a 65 28 26 64 65 6c 74 61 29 3b ob_size(&delta);
1c20: 0a 20 20 20 20 62 6c 6f 62 5f 72 65 73 65 74 28 . blob_reset(
1c30: 26 64 65 6c 74 61 29 3b 0a 20 20 20 20 62 6c 6f &delta);. blo
1c40: 62 5f 72 65 73 65 74 28 26 73 72 63 29 3b 0a 20 b_reset(&src);.
1c50: 20 7d 65 6c 73 65 7b 0a 20 20 20 20 73 69 7a 65 }else{. size
1c60: 20 3d 20 30 3b 0a 20 20 7d 0a 20 20 72 65 74 75 = 0;. }. retu
1c70: 72 6e 20 73 69 7a 65 3b 0a 7d 0a 0a 2f 2a 0a 2a rn size;.}../*.*
1c80: 2a 20 53 65 6e 64 20 74 68 65 20 66 69 6c 65 20 * Send the file
1c90: 69 64 65 6e 74 69 66 69 65 64 20 62 79 20 72 69 identified by ri
1ca0: 64 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 20 70 55 75 d..**.** The pUu
1cb0: 69 64 20 63 61 6e 20 62 65 20 4e 55 4c 4c 20 69 id can be NULL i
1cc0: 6e 20 77 68 69 63 68 20 63 61 73 65 20 74 68 65 n which case the
1cd0: 20 63 6f 72 72 65 63 74 20 55 55 49 44 20 69 73 correct UUID is
1ce0: 20 63 6f 6d 70 75 74 65 64 0a 2a 2a 20 66 72 6f computed.** fro
1cf0: 6d 20 74 68 65 20 72 69 64 2e 0a 2a 2a 0a 2a 2a m the rid..**.**
1d00: 20 54 72 79 20 74 6f 20 73 65 6e 64 20 74 68 65 Try to send the
1d10: 20 66 69 6c 65 20 61 73 20 61 20 6e 61 74 69 76 file as a nativ
1d20: 65 20 64 65 6c 74 61 20 69 66 20 6e 61 74 69 76 e delta if nativ
1d30: 65 44 65 6c 74 61 20 69 73 20 74 72 75 65 2c 20 eDelta is true,
1d40: 6f 72 0a 2a 2a 20 61 73 20 61 20 70 61 72 65 6e or.** as a paren
1d50: 74 20 64 65 6c 74 61 20 69 66 20 6e 61 74 69 76 t delta if nativ
1d60: 65 44 65 6c 74 61 20 69 73 20 66 61 6c 73 65 2e eDelta is false.
1d70: 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 20 .*/.static void
1d80: 73 65 6e 64 5f 66 69 6c 65 28 58 66 65 72 20 2a send_file(Xfer *
1d90: 70 58 66 65 72 2c 20 69 6e 74 20 72 69 64 2c 20 pXfer, int rid,
1da0: 42 6c 6f 62 20 2a 70 55 75 69 64 2c 20 69 6e 74 Blob *pUuid, int
1db0: 20 6e 61 74 69 76 65 44 65 6c 74 61 29 7b 0a 20 nativeDelta){.
1dc0: 20 42 6c 6f 62 20 63 6f 6e 74 65 6e 74 2c 20 75 Blob content, u
1dd0: 75 69 64 3b 0a 20 20 69 6e 74 20 73 69 7a 65 20 uid;. int size
1de0: 3d 20 30 3b 0a 0a 20 20 69 66 28 20 64 62 5f 65 = 0;.. if( db_e
1df0: 78 69 73 74 73 28 22 53 45 4c 45 43 54 20 31 20 xists("SELECT 1
1e00: 46 52 4f 4d 20 6f 6e 72 65 6d 6f 74 65 20 57 48 FROM onremote WH
1e10: 45 52 45 20 72 69 64 3d 25 64 22 2c 20 72 69 64 ERE rid=%d", rid
1e20: 29 20 29 7b 0a 20 20 20 20 20 72 65 74 75 72 6e ) ){. return
1e30: 3b 0a 20 20 7d 0a 20 20 62 6c 6f 62 5f 7a 65 72 ;. }. blob_zer
1e40: 6f 28 26 75 75 69 64 29 3b 0a 20 20 69 66 28 20 o(&uuid);. if(
1e50: 70 55 75 69 64 3d 3d 30 20 29 7b 0a 20 20 20 20 pUuid==0 ){.
1e60: 64 62 5f 62 6c 6f 62 28 26 75 75 69 64 2c 20 22 db_blob(&uuid, "
1e70: 53 45 4c 45 43 54 20 75 75 69 64 20 46 52 4f 4d SELECT uuid FROM
1e80: 20 62 6c 6f 62 20 57 48 45 52 45 20 72 69 64 3d blob WHERE rid=
1e90: 25 64 20 41 4e 44 20 73 69 7a 65 3e 3d 30 22 2c %d AND size>=0",
1ea0: 20 72 69 64 29 3b 0a 20 20 20 20 69 66 28 20 62 rid);. if( b
1eb0: 6c 6f 62 5f 73 69 7a 65 28 26 75 75 69 64 29 3d lob_size(&uuid)=
1ec0: 3d 30 20 29 7b 0a 20 20 20 20 20 20 72 65 74 75 =0 ){. retu
1ed0: 72 6e 3b 0a 20 20 20 20 7d 0a 20 20 20 20 70 55 rn;. }. pU
1ee0: 75 69 64 20 3d 20 26 75 75 69 64 3b 0a 20 20 7d uid = &uuid;. }
1ef0: 0a 20 20 69 66 28 20 70 58 66 65 72 2d 3e 6d 78 . if( pXfer->mx
1f00: 53 65 6e 64 3c 3d 62 6c 6f 62 5f 73 69 7a 65 28 Send<=blob_size(
1f10: 70 58 66 65 72 2d 3e 70 4f 75 74 29 20 29 7b 0a pXfer->pOut) ){.
1f20: 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 blob_appendf
1f30: 28 70 58 66 65 72 2d 3e 70 4f 75 74 2c 20 22 69 (pXfer->pOut, "i
1f40: 67 6f 74 20 25 62 5c 6e 22 2c 20 70 55 75 69 64 got %b\n", pUuid
1f50: 29 3b 0a 20 20 20 20 70 58 66 65 72 2d 3e 6e 49 );. pXfer->nI
1f60: 47 6f 74 53 65 6e 74 2b 2b 3b 0a 20 20 20 20 62 GotSent++;. b
1f70: 6c 6f 62 5f 72 65 73 65 74 28 26 75 75 69 64 29 lob_reset(&uuid)
1f80: 3b 0a 20 20 20 20 72 65 74 75 72 6e 3b 0a 20 20 ;. return;.
1f90: 7d 0a 20 20 69 66 28 20 6e 61 74 69 76 65 44 65 }. if( nativeDe
1fa0: 6c 74 61 20 29 7b 0a 20 20 20 20 73 69 7a 65 20 lta ){. size
1fb0: 3d 20 73 65 6e 64 5f 64 65 6c 74 61 5f 6e 61 74 = send_delta_nat
1fc0: 69 76 65 28 70 58 66 65 72 2c 20 72 69 64 2c 20 ive(pXfer, rid,
1fd0: 70 55 75 69 64 29 3b 0a 20 20 20 20 69 66 28 20 pUuid);. if(
1fe0: 73 69 7a 65 20 29 7b 0a 20 20 20 20 20 20 70 58 size ){. pX
1ff0: 66 65 72 2d 3e 6e 44 65 6c 74 61 53 65 6e 74 2b fer->nDeltaSent+
2000: 2b 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 69 +;. }. }. i
2010: 66 28 20 73 69 7a 65 3d 3d 30 20 29 7b 0a 20 20 f( size==0 ){.
2020: 20 20 63 6f 6e 74 65 6e 74 5f 67 65 74 28 72 69 content_get(ri
2030: 64 2c 20 26 63 6f 6e 74 65 6e 74 29 3b 0a 0a 20 d, &content);..
2040: 20 20 20 69 66 28 20 21 6e 61 74 69 76 65 44 65 if( !nativeDe
2050: 6c 74 61 20 26 26 20 62 6c 6f 62 5f 73 69 7a 65 lta && blob_size
2060: 28 26 63 6f 6e 74 65 6e 74 29 3e 31 30 30 20 29 (&content)>100 )
2070: 7b 0a 20 20 20 20 20 20 73 69 7a 65 20 3d 20 73 {. size = s
2080: 65 6e 64 5f 64 65 6c 74 61 5f 70 61 72 65 6e 74 end_delta_parent
2090: 28 70 58 66 65 72 2c 20 72 69 64 2c 20 26 63 6f (pXfer, rid, &co
20a0: 6e 74 65 6e 74 2c 20 70 55 75 69 64 29 3b 0a 20 ntent, pUuid);.
20b0: 20 20 20 7d 0a 20 20 20 20 69 66 28 20 73 69 7a }. if( siz
20c0: 65 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 69 6e e==0 ){. in
20d0: 74 20 73 69 7a 65 20 3d 20 62 6c 6f 62 5f 73 69 t size = blob_si
20e0: 7a 65 28 26 63 6f 6e 74 65 6e 74 29 3b 0a 20 20 ze(&content);.
20f0: 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 blob_appendf
2100: 28 70 58 66 65 72 2d 3e 70 4f 75 74 2c 20 22 66 (pXfer->pOut, "f
2110: 69 6c 65 20 25 62 20 25 64 5c 6e 22 2c 20 70 55 ile %b %d\n", pU
2120: 75 69 64 2c 20 73 69 7a 65 29 3b 0a 20 20 20 20 uid, size);.
2130: 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 28 70 58 blob_append(pX
2140: 66 65 72 2d 3e 70 4f 75 74 2c 20 62 6c 6f 62 5f fer->pOut, blob_
2150: 62 75 66 66 65 72 28 26 63 6f 6e 74 65 6e 74 29 buffer(&content)
2160: 2c 20 73 69 7a 65 29 3b 0a 20 20 20 20 20 20 70 , size);. p
2170: 58 66 65 72 2d 3e 6e 46 69 6c 65 53 65 6e 74 2b Xfer->nFileSent+
2180: 2b 3b 0a 20 20 20 20 7d 65 6c 73 65 7b 0a 20 20 +;. }else{.
2190: 20 20 20 20 70 58 66 65 72 2d 3e 6e 44 65 6c 74 pXfer->nDelt
21a0: 61 53 65 6e 74 2b 2b 3b 0a 20 20 20 20 7d 0a 20 aSent++;. }.
21b0: 20 7d 0a 20 20 72 65 6d 6f 74 65 5f 68 61 73 28 }. remote_has(
21c0: 72 69 64 29 3b 0a 20 20 62 6c 6f 62 5f 72 65 73 rid);. blob_res
21d0: 65 74 28 26 75 75 69 64 29 3b 0a 7d 0a 0a 2f 2a et(&uuid);.}../*
21e0: 0a 2a 2a 20 53 65 6e 64 20 61 20 67 69 6d 6d 65 .** Send a gimme
21f0: 20 6d 65 73 73 61 67 65 20 66 6f 72 20 65 76 65 message for eve
2200: 72 79 20 70 68 61 6e 74 6f 6d 2e 0a 2a 2f 0a 73 ry phantom..*/.s
2210: 74 61 74 69 63 20 76 6f 69 64 20 72 65 71 75 65 tatic void reque
2220: 73 74 5f 70 68 61 6e 74 6f 6d 73 28 58 66 65 72 st_phantoms(Xfer
2230: 20 2a 70 58 66 65 72 2c 20 69 6e 74 20 6d 61 78 *pXfer, int max
2240: 52 65 71 29 7b 0a 20 20 53 74 6d 74 20 71 3b 0a Req){. Stmt q;.
2250: 20 20 64 62 5f 70 72 65 70 61 72 65 28 26 71 2c db_prepare(&q,
2260: 20 0a 20 20 20 20 22 53 45 4c 45 43 54 20 75 75 . "SELECT uu
2270: 69 64 20 46 52 4f 4d 20 70 68 61 6e 74 6f 6d 20 id FROM phantom
2280: 4a 4f 49 4e 20 62 6c 6f 62 20 55 53 49 4e 47 28 JOIN blob USING(
2290: 72 69 64 29 22 0a 20 20 20 20 22 20 57 48 45 52 rid)". " WHER
22a0: 45 20 4e 4f 54 20 45 58 49 53 54 53 28 53 45 4c E NOT EXISTS(SEL
22b0: 45 43 54 20 31 20 46 52 4f 4d 20 73 68 75 6e 20 ECT 1 FROM shun
22c0: 57 48 45 52 45 20 75 75 69 64 3d 62 6c 6f 62 2e WHERE uuid=blob.
22d0: 75 75 69 64 29 22 0a 20 20 29 3b 0a 20 20 77 68 uuid)". );. wh
22e0: 69 6c 65 28 20 64 62 5f 73 74 65 70 28 26 71 29 ile( db_step(&q)
22f0: 3d 3d 53 51 4c 49 54 45 5f 52 4f 57 20 26 26 20 ==SQLITE_ROW &&
2300: 6d 61 78 52 65 71 2d 2d 20 3e 20 30 20 29 7b 0a maxReq-- > 0 ){.
2310: 20 20 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a const char *
2320: 7a 55 75 69 64 20 3d 20 64 62 5f 63 6f 6c 75 6d zUuid = db_colum
2330: 6e 5f 74 65 78 74 28 26 71 2c 20 30 29 3b 0a 20 n_text(&q, 0);.
2340: 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 28 blob_appendf(
2350: 70 58 66 65 72 2d 3e 70 4f 75 74 2c 20 22 67 69 pXfer->pOut, "gi
2360: 6d 6d 65 20 25 73 5c 6e 22 2c 20 7a 55 75 69 64 mme %s\n", zUuid
2370: 29 3b 0a 20 20 20 20 70 58 66 65 72 2d 3e 6e 47 );. pXfer->nG
2380: 69 6d 6d 65 53 65 6e 74 2b 2b 3b 0a 20 20 7d 0a immeSent++;. }.
2390: 20 20 64 62 5f 66 69 6e 61 6c 69 7a 65 28 26 71 db_finalize(&q
23a0: 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 6f 6d 70 );.}../*.** Comp
23b0: 75 74 65 20 61 6e 20 53 48 41 31 20 68 61 73 68 ute an SHA1 hash
23c0: 20 6f 6e 20 74 68 65 20 74 61 69 6c 20 6f 66 20 on the tail of
23d0: 70 4d 73 67 2e 20 20 56 65 72 69 66 79 20 74 68 pMsg. Verify th
23e0: 61 74 20 69 74 20 6d 61 74 63 68 65 73 20 74 68 at it matches th
23f0: 65 0a 2a 2a 20 74 68 65 20 68 61 73 68 20 67 69 e.** the hash gi
2400: 76 65 6e 20 69 6e 20 70 48 61 73 68 2e 20 20 52 ven in pHash. R
2410: 65 74 75 72 6e 20 31 20 6f 6e 20 61 20 73 75 63 eturn 1 on a suc
2420: 63 65 73 73 66 75 6c 20 6d 61 74 63 68 2e 20 20 cessful match.
2430: 52 65 74 75 72 6e 20 30 0a 2a 2a 20 69 66 20 74 Return 0.** if t
2440: 68 65 72 65 20 69 73 20 61 20 6d 69 73 6d 61 74 here is a mismat
2450: 63 68 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 69 6e ch..*/.static in
2460: 74 20 63 68 65 63 6b 5f 74 61 69 6c 5f 68 61 73 t check_tail_has
2470: 68 28 42 6c 6f 62 20 2a 70 48 61 73 68 2c 20 42 h(Blob *pHash, B
2480: 6c 6f 62 20 2a 70 4d 73 67 29 7b 0a 20 20 42 6c lob *pMsg){. Bl
2490: 6f 62 20 74 61 69 6c 3b 0a 20 20 42 6c 6f 62 20 ob tail;. Blob
24a0: 68 32 3b 0a 20 20 69 6e 74 20 72 63 3b 0a 20 20 h2;. int rc;.
24b0: 62 6c 6f 62 5f 74 61 69 6c 28 70 4d 73 67 2c 20 blob_tail(pMsg,
24c0: 26 74 61 69 6c 29 3b 0a 20 20 73 68 61 31 73 75 &tail);. sha1su
24d0: 6d 5f 62 6c 6f 62 28 26 74 61 69 6c 2c 20 26 68 m_blob(&tail, &h
24e0: 32 29 3b 0a 20 20 72 63 20 3d 20 62 6c 6f 62 5f 2);. rc = blob_
24f0: 63 6f 6d 70 61 72 65 28 70 48 61 73 68 2c 20 26 compare(pHash, &
2500: 68 32 29 3b 0a 20 20 62 6c 6f 62 5f 72 65 73 65 h2);. blob_rese
2510: 74 28 26 68 32 29 3b 0a 20 20 62 6c 6f 62 5f 72 t(&h2);. blob_r
2520: 65 73 65 74 28 26 74 61 69 6c 29 3b 0a 20 20 72 eset(&tail);. r
2530: 65 74 75 72 6e 20 72 63 3d 3d 30 3b 0a 7d 0a 0a eturn rc==0;.}..
2540: 0a 2f 2a 0a 2a 2a 20 43 68 65 63 6b 20 74 68 65 ./*.** Check the
2550: 20 73 69 67 6e 61 74 75 72 65 20 6f 6e 20 61 6e signature on an
2560: 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f 78 2d 66 application/x-f
2570: 6f 73 73 69 6c 20 70 61 79 6c 6f 61 64 20 72 65 ossil payload re
2580: 63 65 69 76 65 64 20 62 79 0a 2a 2a 20 74 68 65 ceived by.** the
2590: 20 48 54 54 50 20 73 65 72 76 65 72 2e 20 20 54 HTTP server. T
25a0: 68 65 20 73 69 67 6e 61 74 75 72 65 20 69 73 20 he signature is
25b0: 61 20 6c 69 6e 65 20 6f 66 20 74 68 65 20 66 6f a line of the fo
25c0: 6c 6c 6f 77 69 6e 67 20 66 6f 72 6d 3a 0a 2a 2a llowing form:.**
25d0: 0a 2a 2a 20 20 20 20 20 20 20 20 6c 6f 67 69 6e .** login
25e0: 20 4c 4f 47 49 4e 20 4e 4f 4e 43 45 20 53 49 47 LOGIN NONCE SIG
25f0: 4e 41 54 55 52 45 0a 2a 2a 0a 2a 2a 20 54 68 65 NATURE.**.** The
2600: 20 4e 4f 4e 43 45 20 69 73 20 74 68 65 20 53 48 NONCE is the SH
2610: 41 31 20 68 61 73 68 20 6f 66 20 74 68 65 20 72 A1 hash of the r
2620: 65 6d 61 69 6e 64 65 72 20 6f 66 20 74 68 65 20 emainder of the
2630: 69 6e 70 75 74 2e 20 20 0a 2a 2a 20 53 49 47 4e input. .** SIGN
2640: 41 54 55 52 45 20 69 73 20 74 68 65 20 53 48 41 ATURE is the SHA
2650: 31 20 63 68 65 63 6b 73 75 6d 20 6f 66 20 74 68 1 checksum of th
2660: 65 20 4e 4f 4e 43 45 20 63 6f 6e 63 61 74 65 6e e NONCE concaten
2670: 61 74 65 64 20 0a 2a 2a 20 77 69 74 68 20 74 68 ated .** with th
2680: 65 20 75 73 65 72 73 20 70 61 73 73 77 6f 72 64 e users password
2690: 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 20 70 61 72 61 ..**.** The para
26a0: 6d 65 74 65 72 73 20 74 6f 20 74 68 69 73 20 72 meters to this r
26b0: 6f 75 74 69 6e 65 20 61 72 65 20 65 70 68 65 72 outine are epher
26c0: 6d 65 72 61 6c 20 62 6c 6f 62 73 20 68 6f 6c 64 meral blobs hold
26d0: 69 6e 67 20 74 68 65 0a 2a 2a 20 4c 4f 47 49 4e ing the.** LOGIN
26e0: 2c 20 4e 4f 4e 43 45 20 61 6e 64 20 53 49 47 4e , NONCE and SIGN
26f0: 41 54 55 52 45 2e 0a 2a 2a 0a 2a 2a 20 54 68 69 ATURE..**.** Thi
2700: 73 20 72 6f 75 74 69 6e 65 20 61 74 74 65 6d 70 s routine attemp
2710: 74 73 20 74 6f 20 6c 6f 63 61 74 65 20 74 68 65 ts to locate the
2720: 20 75 73 65 72 20 61 6e 64 20 76 65 72 69 66 79 user and verify
2730: 20 74 68 65 20 73 69 67 6e 61 74 75 72 65 2e 0a the signature..
2740: 2a 2a 20 49 66 20 65 76 65 72 79 74 68 69 6e 67 ** If everything
2750: 20 63 68 65 63 6b 73 20 6f 75 74 2c 20 74 68 65 checks out, the
2760: 20 55 53 45 52 2e 43 41 50 20 63 6f 6c 75 6d 6e USER.CAP column
2770: 20 66 6f 72 20 74 68 65 20 55 53 45 52 20 74 61 for the USER ta
2780: 62 6c 65 0a 2a 2a 20 69 73 20 63 6f 6e 73 75 6c ble.** is consul
2790: 74 65 64 20 74 6f 20 73 65 74 20 70 72 69 76 69 ted to set privi
27a0: 6c 65 67 65 73 20 69 6e 20 74 68 65 20 67 6c 6f leges in the glo
27b0: 62 61 6c 20 67 20 76 61 72 69 61 62 6c 65 2e 0a bal g variable..
27c0: 2a 2a 0a 2a 2a 20 49 66 20 61 6e 79 74 68 69 6e **.** If anythin
27d0: 67 20 66 61 69 6c 73 20 74 6f 20 63 68 65 63 6b g fails to check
27e0: 20 6f 75 74 2c 20 6e 6f 20 63 68 61 6e 67 65 73 out, no changes
27f0: 20 61 72 65 20 6d 61 64 65 20 74 6f 20 70 72 69 are made to pri
2800: 76 69 6c 65 67 65 73 2e 0a 2a 2a 0a 2a 2a 20 53 vileges..**.** S
2810: 69 67 6e 61 74 75 72 65 20 67 65 6e 65 72 61 74 ignature generat
2820: 69 6f 6e 20 6f 6e 20 74 68 65 20 63 6c 69 65 6e ion on the clien
2830: 74 20 73 69 64 65 20 69 73 20 68 61 6e 64 6c 65 t side is handle
2840: 64 20 62 79 20 74 68 65 20 0a 2a 2a 20 68 74 74 d by the .** htt
2850: 70 5f 65 78 63 68 61 6e 67 65 28 29 20 72 6f 75 p_exchange() rou
2860: 74 69 6e 65 2e 0a 2a 2f 0a 76 6f 69 64 20 63 68 tine..*/.void ch
2870: 65 63 6b 5f 6c 6f 67 69 6e 28 42 6c 6f 62 20 2a eck_login(Blob *
2880: 70 4c 6f 67 69 6e 2c 20 42 6c 6f 62 20 2a 70 4e pLogin, Blob *pN
2890: 6f 6e 63 65 2c 20 42 6c 6f 62 20 2a 70 53 69 67 once, Blob *pSig
28a0: 29 7b 0a 20 20 53 74 6d 74 20 71 3b 0a 20 20 69 ){. Stmt q;. i
28b0: 6e 74 20 72 63 3b 0a 0a 20 20 64 62 5f 70 72 65 nt rc;.. db_pre
28c0: 70 61 72 65 28 26 71 2c 20 22 53 45 4c 45 43 54 pare(&q, "SELECT
28d0: 20 70 77 2c 20 63 61 70 2c 20 75 69 64 20 46 52 pw, cap, uid FR
28e0: 4f 4d 20 75 73 65 72 20 57 48 45 52 45 20 6c 6f OM user WHERE lo
28f0: 67 69 6e 3d 25 42 22 2c 20 70 4c 6f 67 69 6e 29 gin=%B", pLogin)
2900: 3b 0a 20 20 69 66 28 20 64 62 5f 73 74 65 70 28 ;. if( db_step(
2910: 26 71 29 3d 3d 53 51 4c 49 54 45 5f 52 4f 57 20 &q)==SQLITE_ROW
2920: 29 7b 0a 20 20 20 20 42 6c 6f 62 20 70 77 2c 20 ){. Blob pw,
2930: 63 6f 6d 62 69 6e 65 64 2c 20 68 61 73 68 3b 0a combined, hash;.
2940: 20 20 20 20 62 6c 6f 62 5f 7a 65 72 6f 28 26 70 blob_zero(&p
2950: 77 29 3b 0a 20 20 20 20 64 62 5f 65 70 68 65 6d w);. db_ephem
2960: 65 72 61 6c 5f 62 6c 6f 62 28 26 71 2c 20 30 2c eral_blob(&q, 0,
2970: 20 26 70 77 29 3b 0a 20 20 20 20 62 6c 6f 62 5f &pw);. blob_
2980: 7a 65 72 6f 28 26 63 6f 6d 62 69 6e 65 64 29 3b zero(&combined);
2990: 0a 20 20 20 20 62 6c 6f 62 5f 63 6f 70 79 28 26 . blob_copy(&
29a0: 63 6f 6d 62 69 6e 65 64 2c 20 70 4e 6f 6e 63 65 combined, pNonce
29b0: 29 3b 0a 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 );. blob_appe
29c0: 6e 64 28 26 63 6f 6d 62 69 6e 65 64 2c 20 62 6c nd(&combined, bl
29d0: 6f 62 5f 62 75 66 66 65 72 28 26 70 77 29 2c 20 ob_buffer(&pw),
29e0: 62 6c 6f 62 5f 73 69 7a 65 28 26 70 77 29 29 3b blob_size(&pw));
29f0: 0a 20 20 20 20 2f 2a 20 43 47 49 44 45 42 55 47 . /* CGIDEBUG
2a00: 28 28 22 70 72 65 73 69 67 3d 5b 25 73 5d 5c 6e (("presig=[%s]\n
2a10: 22 2c 20 62 6c 6f 62 5f 73 74 72 28 26 63 6f 6d ", blob_str(&com
2a20: 62 69 6e 65 64 29 29 29 3b 20 2a 2f 0a 20 20 20 bined))); */.
2a30: 20 73 68 61 31 73 75 6d 5f 62 6c 6f 62 28 26 63 sha1sum_blob(&c
2a40: 6f 6d 62 69 6e 65 64 2c 20 26 68 61 73 68 29 3b ombined, &hash);
2a50: 0a 20 20 20 20 72 63 20 3d 20 62 6c 6f 62 5f 63 . rc = blob_c
2a60: 6f 6d 70 61 72 65 28 26 68 61 73 68 2c 20 70 53 ompare(&hash, pS
2a70: 69 67 29 3b 0a 20 20 20 20 62 6c 6f 62 5f 72 65 ig);. blob_re
2a80: 73 65 74 28 26 68 61 73 68 29 3b 0a 20 20 20 20 set(&hash);.
2a90: 62 6c 6f 62 5f 72 65 73 65 74 28 26 63 6f 6d 62 blob_reset(&comb
2aa0: 69 6e 65 64 29 3b 0a 20 20 20 20 69 66 28 20 72 ined);. if( r
2ab0: 63 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 63 6f c==0 ){. co
2ac0: 6e 73 74 20 63 68 61 72 20 2a 7a 43 61 70 3b 0a nst char *zCap;.
2ad0: 20 20 20 20 20 20 7a 43 61 70 20 3d 20 64 62 5f zCap = db_
2ae0: 63 6f 6c 75 6d 6e 5f 74 65 78 74 28 26 71 2c 20 column_text(&q,
2af0: 31 29 3b 0a 20 20 20 20 20 20 6c 6f 67 69 6e 5f 1);. login_
2b00: 73 65 74 5f 63 61 70 61 62 69 6c 69 74 69 65 73 set_capabilities
2b10: 28 7a 43 61 70 29 3b 0a 20 20 20 20 20 20 67 2e (zCap);. g.
2b20: 75 73 65 72 55 69 64 20 3d 20 64 62 5f 63 6f 6c userUid = db_col
2b30: 75 6d 6e 5f 69 6e 74 28 26 71 2c 20 32 29 3b 0a umn_int(&q, 2);.
2b40: 20 20 20 20 20 20 67 2e 7a 4c 6f 67 69 6e 20 3d g.zLogin =
2b50: 20 6d 70 72 69 6e 74 66 28 22 25 62 22 2c 20 70 mprintf("%b", p
2b60: 4c 6f 67 69 6e 29 3b 0a 20 20 20 20 20 20 67 2e Login);. g.
2b70: 7a 4e 6f 6e 63 65 20 3d 20 6d 70 72 69 6e 74 66 zNonce = mprintf
2b80: 28 22 25 62 22 2c 20 70 4e 6f 6e 63 65 29 3b 0a ("%b", pNonce);.
2b90: 20 20 20 20 7d 0a 20 20 7d 0a 20 20 64 62 5f 72 }. }. db_r
2ba0: 65 73 65 74 28 26 71 29 3b 0a 7d 0a 0a 2f 2a 0a eset(&q);.}../*.
2bb0: 2a 2a 20 53 65 6e 64 20 74 68 65 20 63 6f 6e 74 ** Send the cont
2bc0: 65 6e 74 20 6f 66 20 61 6c 6c 20 66 69 6c 65 73 ent of all files
2bd0: 20 69 6e 20 74 68 65 20 75 6e 73 65 6e 74 20 74 in the unsent t
2be0: 61 62 6c 65 2e 0a 2a 2a 0a 2a 2a 20 54 68 69 73 able..**.** This
2bf0: 20 69 73 20 72 65 61 6c 6c 79 20 6a 75 73 74 20 is really just
2c00: 61 6e 20 6f 70 74 69 6d 69 7a 61 74 69 6f 6e 2e an optimization.
2c10: 20 20 49 66 20 79 6f 75 20 63 6c 65 61 72 20 74 If you clear t
2c20: 68 65 0a 2a 2a 20 75 6e 73 65 6e 74 20 74 61 62 he.** unsent tab
2c30: 6c 65 2c 20 61 6c 6c 20 74 68 65 20 72 69 67 68 le, all the righ
2c40: 74 20 66 69 6c 65 73 20 77 69 6c 6c 20 73 74 69 t files will sti
2c50: 6c 6c 20 67 65 74 20 74 72 61 6e 73 66 65 72 72 ll get transferr
2c60: 65 64 2e 0a 2a 2a 20 49 74 20 6a 75 73 74 20 6d ed..** It just m
2c70: 69 67 68 74 20 72 65 71 75 69 72 65 20 61 6e 20 ight require an
2c80: 65 78 74 72 61 20 72 6f 75 6e 64 20 74 72 69 70 extra round trip
2c90: 20 6f 72 20 74 77 6f 2e 0a 2a 2f 0a 73 74 61 74 or two..*/.stat
2ca0: 69 63 20 76 6f 69 64 20 73 65 6e 64 5f 75 6e 73 ic void send_uns
2cb0: 65 6e 74 28 58 66 65 72 20 2a 70 58 66 65 72 29 ent(Xfer *pXfer)
2cc0: 7b 0a 20 20 53 74 6d 74 20 71 3b 0a 20 20 64 62 {. Stmt q;. db
2cd0: 5f 70 72 65 70 61 72 65 28 26 71 2c 20 22 53 45 _prepare(&q, "SE
2ce0: 4c 45 43 54 20 72 69 64 20 46 52 4f 4d 20 75 6e LECT rid FROM un
2cf0: 73 65 6e 74 22 29 3b 0a 20 20 77 68 69 6c 65 28 sent");. while(
2d00: 20 64 62 5f 73 74 65 70 28 26 71 29 3d 3d 53 51 db_step(&q)==SQ
2d10: 4c 49 54 45 5f 52 4f 57 20 29 7b 0a 20 20 20 20 LITE_ROW ){.
2d20: 69 6e 74 20 72 69 64 20 3d 20 64 62 5f 63 6f 6c int rid = db_col
2d30: 75 6d 6e 5f 69 6e 74 28 26 71 2c 20 30 29 3b 0a umn_int(&q, 0);.
2d40: 20 20 20 20 73 65 6e 64 5f 66 69 6c 65 28 70 58 send_file(pX
2d50: 66 65 72 2c 20 72 69 64 2c 20 30 2c 20 30 29 3b fer, rid, 0, 0);
2d60: 0a 20 20 7d 0a 20 20 64 62 5f 66 69 6e 61 6c 69 . }. db_finali
2d70: 7a 65 28 26 71 29 3b 0a 20 20 64 62 5f 6d 75 6c ze(&q);. db_mul
2d80: 74 69 5f 65 78 65 63 28 22 44 45 4c 45 54 45 20 ti_exec("DELETE
2d90: 46 52 4f 4d 20 75 6e 73 65 6e 74 22 29 3b 0a 7d FROM unsent");.}
2da0: 0a 0a 2f 2a 0a 2a 2a 20 43 68 65 63 6b 20 74 6f ../*.** Check to
2db0: 20 73 65 65 20 69 66 20 74 68 65 20 6e 75 6d 62 see if the numb
2dc0: 65 72 20 6f 66 20 75 6e 63 6c 75 73 74 65 72 65 er of unclustere
2dd0: 64 20 65 6e 74 72 69 65 73 20 69 73 20 67 72 65 d entries is gre
2de0: 61 74 65 72 20 74 68 61 6e 0a 2a 2a 20 31 30 30 ater than.** 100
2df0: 20 61 6e 64 20 69 66 20 69 74 20 69 73 2c 20 66 and if it is, f
2e00: 6f 72 6d 20 61 20 6e 65 77 20 63 6c 75 73 74 65 orm a new cluste
2e10: 72 2e 20 20 55 6e 63 6c 75 73 74 65 72 65 64 20 r. Unclustered
2e20: 70 68 61 6e 74 6f 6d 73 20 64 6f 20 6e 6f 74 0a phantoms do not.
2e30: 2a 2a 20 63 6f 75 6e 74 20 74 6f 77 61 72 64 20 ** count toward
2e40: 74 68 65 20 31 30 30 20 74 6f 74 61 6c 2e 20 20 the 100 total.
2e50: 41 6e 64 20 70 68 61 6e 74 6f 6d 73 20 61 72 65 And phantoms are
2e60: 20 6e 65 76 65 72 20 61 64 64 65 64 20 74 6f 20 never added to
2e70: 61 20 6e 65 77 0a 2a 2a 20 63 6c 75 73 74 65 72 a new.** cluster
2e80: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 ..*/.static void
2e90: 20 63 72 65 61 74 65 5f 63 6c 75 73 74 65 72 28 create_cluster(
2ea0: 76 6f 69 64 29 7b 0a 20 20 42 6c 6f 62 20 63 6c void){. Blob cl
2eb0: 75 73 74 65 72 2c 20 63 6b 73 75 6d 3b 0a 20 20 uster, cksum;.
2ec0: 53 74 6d 74 20 71 3b 0a 20 20 69 6e 74 20 6e 55 Stmt q;. int nU
2ed0: 6e 63 6c 3b 0a 20 20 6e 55 6e 63 6c 20 3d 20 64 ncl;. nUncl = d
2ee0: 62 5f 69 6e 74 28 30 2c 20 22 53 45 4c 45 43 54 b_int(0, "SELECT
2ef0: 20 63 6f 75 6e 74 28 2a 29 20 46 52 4f 4d 20 75 count(*) FROM u
2f00: 6e 63 6c 75 73 74 65 72 65 64 22 0a 20 20 20 20 nclustered".
2f10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2f20: 22 20 57 48 45 52 45 20 4e 4f 54 20 45 58 49 53 " WHERE NOT EXIS
2f30: 54 53 28 53 45 4c 45 43 54 20 31 20 46 52 4f 4d TS(SELECT 1 FROM
2f40: 20 70 68 61 6e 74 6f 6d 22 0a 20 20 20 20 20 20 phantom".
2f50: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2f60: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2f70: 22 20 57 48 45 52 45 20 72 69 64 3d 75 6e 63 6c " WHERE rid=uncl
2f80: 75 73 74 65 72 65 64 2e 72 69 64 29 22 29 3b 0a ustered.rid)");.
2f90: 20 20 69 66 28 20 6e 55 6e 63 6c 3c 31 30 30 20 if( nUncl<100
2fa0: 29 7b 0a 20 20 20 20 72 65 74 75 72 6e 3b 0a 20 ){. return;.
2fb0: 20 7d 0a 20 20 62 6c 6f 62 5f 7a 65 72 6f 28 26 }. blob_zero(&
2fc0: 63 6c 75 73 74 65 72 29 3b 0a 20 20 64 62 5f 70 cluster);. db_p
2fd0: 72 65 70 61 72 65 28 26 71 2c 20 22 53 45 4c 45 repare(&q, "SELE
2fe0: 43 54 20 75 75 69 64 20 46 52 4f 4d 20 75 6e 63 CT uuid FROM unc
2ff0: 6c 75 73 74 65 72 65 64 2c 20 62 6c 6f 62 22 0a lustered, blob".
3000: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
3010: 20 22 20 57 48 45 52 45 20 4e 4f 54 20 45 58 49 " WHERE NOT EXI
3020: 53 54 53 28 53 45 4c 45 43 54 20 31 20 46 52 4f STS(SELECT 1 FRO
3030: 4d 20 70 68 61 6e 74 6f 6d 22 0a 20 20 20 20 20 M phantom".
3040: 20 20 20 20 20 20 20 20 20 20 20 20 22 20 20 20 "
3050: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
3060: 57 48 45 52 45 20 72 69 64 21 3d 75 6e 63 6c 75 WHERE rid!=unclu
3070: 73 74 65 72 65 64 2e 72 69 64 29 22 0a 20 20 20 stered.rid)".
3080: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 22 20 "
3090: 20 20 41 4e 44 20 75 6e 63 6c 75 73 74 65 72 65 AND unclustere
30a0: 64 2e 72 69 64 3d 62 6c 6f 62 2e 72 69 64 22 0a d.rid=blob.rid".
30b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
30c0: 20 22 20 4f 52 44 45 52 20 42 59 20 31 22 29 3b " ORDER BY 1");
30d0: 0a 20 20 77 68 69 6c 65 28 20 64 62 5f 73 74 65 . while( db_ste
30e0: 70 28 26 71 29 3d 3d 53 51 4c 49 54 45 5f 52 4f p(&q)==SQLITE_RO
30f0: 57 20 29 7b 0a 20 20 20 20 62 6c 6f 62 5f 61 70 W ){. blob_ap
3100: 70 65 6e 64 66 28 26 63 6c 75 73 74 65 72 2c 20 pendf(&cluster,
3110: 22 4d 20 25 73 5c 6e 22 2c 20 64 62 5f 63 6f 6c "M %s\n", db_col
3120: 75 6d 6e 5f 74 65 78 74 28 26 71 2c 20 30 29 29 umn_text(&q, 0))
3130: 3b 0a 20 20 7d 0a 20 20 64 62 5f 66 69 6e 61 6c ;. }. db_final
3140: 69 7a 65 28 26 71 29 3b 0a 20 20 6d 64 35 73 75 ize(&q);. md5su
3150: 6d 5f 62 6c 6f 62 28 26 63 6c 75 73 74 65 72 2c m_blob(&cluster,
3160: 20 26 63 6b 73 75 6d 29 3b 0a 20 20 62 6c 6f 62 &cksum);. blob
3170: 5f 61 70 70 65 6e 64 66 28 26 63 6c 75 73 74 65 _appendf(&cluste
3180: 72 2c 20 22 5a 20 25 62 5c 6e 22 2c 20 26 63 6b r, "Z %b\n", &ck
3190: 73 75 6d 29 3b 0a 20 20 62 6c 6f 62 5f 72 65 73 sum);. blob_res
31a0: 65 74 28 26 63 6b 73 75 6d 29 3b 0a 20 20 64 62 et(&cksum);. db
31b0: 5f 6d 75 6c 74 69 5f 65 78 65 63 28 22 44 45 4c _multi_exec("DEL
31c0: 45 54 45 20 46 52 4f 4d 20 75 6e 63 6c 75 73 74 ETE FROM unclust
31d0: 65 72 65 64 22 29 3b 0a 20 20 63 6f 6e 74 65 6e ered");. conten
31e0: 74 5f 70 75 74 28 26 63 6c 75 73 74 65 72 2c 20 t_put(&cluster,
31f0: 30 2c 20 30 29 3b 0a 20 20 62 6c 6f 62 5f 72 65 0, 0);. blob_re
3200: 73 65 74 28 26 63 6c 75 73 74 65 72 29 3b 0a 7d set(&cluster);.}
3210: 0a 0a 2f 2a 0a 2a 2a 20 53 65 6e 64 20 61 6e 20 ../*.** Send an
3220: 69 67 6f 74 20 6d 65 73 73 61 67 65 20 66 6f 72 igot message for
3230: 20 65 76 65 72 79 20 65 6e 74 72 79 20 69 6e 20 every entry in
3240: 75 6e 63 6c 75 73 74 65 72 65 64 20 74 61 62 6c unclustered tabl
3250: 65 2e 0a 2a 2a 20 52 65 74 75 72 6e 20 74 68 65 e..** Return the
3260: 20 6e 75 6d 62 65 72 20 6f 66 20 6d 65 73 73 61 number of messa
3270: 67 65 73 20 73 65 6e 74 2e 0a 2a 2f 0a 73 74 61 ges sent..*/.sta
3280: 74 69 63 20 69 6e 74 20 73 65 6e 64 5f 75 6e 63 tic int send_unc
3290: 6c 75 73 74 65 72 65 64 28 58 66 65 72 20 2a 70 lustered(Xfer *p
32a0: 58 66 65 72 29 7b 0a 20 20 53 74 6d 74 20 71 3b Xfer){. Stmt q;
32b0: 0a 20 20 69 6e 74 20 63 6e 74 20 3d 20 30 3b 0a . int cnt = 0;.
32c0: 20 20 64 62 5f 70 72 65 70 61 72 65 28 26 71 2c db_prepare(&q,
32d0: 20 0a 20 20 20 20 22 53 45 4c 45 43 54 20 75 75 . "SELECT uu
32e0: 69 64 20 46 52 4f 4d 20 75 6e 63 6c 75 73 74 65 id FROM uncluste
32f0: 72 65 64 20 4a 4f 49 4e 20 62 6c 6f 62 20 55 53 red JOIN blob US
3300: 49 4e 47 28 72 69 64 29 22 0a 20 20 20 20 22 20 ING(rid)". "
3310: 57 48 45 52 45 20 4e 4f 54 20 45 58 49 53 54 53 WHERE NOT EXISTS
3320: 28 53 45 4c 45 43 54 20 31 20 46 52 4f 4d 20 73 (SELECT 1 FROM s
3330: 68 75 6e 20 57 48 45 52 45 20 75 75 69 64 3d 62 hun WHERE uuid=b
3340: 6c 6f 62 2e 75 75 69 64 29 22 0a 20 20 29 3b 0a lob.uuid)". );.
3350: 20 20 77 68 69 6c 65 28 20 64 62 5f 73 74 65 70 while( db_step
3360: 28 26 71 29 3d 3d 53 51 4c 49 54 45 5f 52 4f 57 (&q)==SQLITE_ROW
3370: 20 29 7b 0a 20 20 20 20 62 6c 6f 62 5f 61 70 70 ){. blob_app
3380: 65 6e 64 66 28 70 58 66 65 72 2d 3e 70 4f 75 74 endf(pXfer->pOut
3390: 2c 20 22 69 67 6f 74 20 25 73 5c 6e 22 2c 20 64 , "igot %s\n", d
33a0: 62 5f 63 6f 6c 75 6d 6e 5f 74 65 78 74 28 26 71 b_column_text(&q
33b0: 2c 20 30 29 29 3b 0a 20 20 20 20 63 6e 74 2b 2b , 0));. cnt++
33c0: 3b 0a 20 20 7d 0a 20 20 64 62 5f 66 69 6e 61 6c ;. }. db_final
33d0: 69 7a 65 28 26 71 29 3b 0a 20 20 72 65 74 75 72 ize(&q);. retur
33e0: 6e 20 63 6e 74 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 n cnt;.}../*.**
33f0: 49 66 20 74 68 69 73 20 76 61 72 69 61 62 6c 65 If this variable
3400: 20 69 73 20 73 65 74 2c 20 64 69 73 61 62 6c 65 is set, disable
3410: 20 6c 6f 67 69 6e 20 63 68 65 63 6b 73 2e 20 20 login checks.
3420: 55 73 65 64 20 66 6f 72 20 64 65 62 75 67 67 69 Used for debuggi
3430: 6e 67 0a 2a 2a 20 6f 6e 6c 79 2e 0a 2a 2f 0a 73 ng.** only..*/.s
3440: 74 61 74 69 63 20 69 6e 74 20 64 69 73 61 62 6c tatic int disabl
3450: 65 4c 6f 67 69 6e 20 3d 20 30 3b 0a 0a 2f 2a 0a eLogin = 0;../*.
3460: 2a 2a 20 57 45 42 50 41 47 45 3a 20 78 66 65 72 ** WEBPAGE: xfer
3470: 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 69 73 20 74 .**.** This is t
3480: 68 65 20 74 72 61 6e 73 66 65 72 20 68 61 6e 64 he transfer hand
3490: 6c 65 72 20 6f 6e 20 74 68 65 20 73 65 72 76 65 ler on the serve
34a0: 72 20 73 69 64 65 2e 20 20 54 68 65 20 74 72 61 r side. The tra
34b0: 6e 73 66 65 72 0a 2a 2a 20 6d 65 73 73 61 67 65 nsfer.** message
34c0: 20 68 61 73 20 62 65 65 6e 20 75 6e 63 6f 6d 70 has been uncomp
34d0: 72 65 73 73 65 64 20 61 6e 64 20 70 6c 61 63 65 ressed and place
34e0: 64 20 69 6e 20 74 68 65 20 67 2e 63 67 69 49 6e d in the g.cgiIn
34f0: 20 62 6c 6f 62 2e 0a 2a 2a 20 50 72 6f 63 65 73 blob..** Proces
3500: 73 20 74 68 69 73 20 6d 65 73 73 61 67 65 20 61 s this message a
3510: 6e 64 20 66 6f 72 6d 20 61 6e 20 61 70 70 72 6f nd form an appro
3520: 70 72 69 61 74 65 20 72 65 70 6c 79 2e 0a 2a 2f priate reply..*/
3530: 0a 76 6f 69 64 20 70 61 67 65 5f 78 66 65 72 28 .void page_xfer(
3540: 76 6f 69 64 29 7b 0a 20 20 69 6e 74 20 69 73 50 void){. int isP
3550: 75 6c 6c 20 3d 20 30 3b 0a 20 20 69 6e 74 20 69 ull = 0;. int i
3560: 73 50 75 73 68 20 3d 20 30 3b 0a 20 20 69 6e 74 sPush = 0;. int
3570: 20 6e 45 72 72 20 3d 20 30 3b 0a 20 20 58 66 65 nErr = 0;. Xfe
3580: 72 20 78 66 65 72 3b 0a 20 20 69 6e 74 20 64 65 r xfer;. int de
3590: 6c 74 61 46 6c 61 67 20 3d 20 30 3b 0a 0a 20 20 ltaFlag = 0;..
35a0: 6d 65 6d 73 65 74 28 26 78 66 65 72 2c 20 30 2c memset(&xfer, 0,
35b0: 20 73 69 7a 65 6f 66 28 78 66 65 72 29 29 3b 0a sizeof(xfer));.
35c0: 20 20 62 6c 6f 62 61 72 72 61 79 5f 7a 65 72 6f blobarray_zero
35d0: 28 78 66 65 72 2e 61 54 6f 6b 65 6e 2c 20 63 6f (xfer.aToken, co
35e0: 75 6e 74 28 78 66 65 72 2e 61 54 6f 6b 65 6e 29 unt(xfer.aToken)
35f0: 29 3b 0a 20 20 63 67 69 5f 73 65 74 5f 63 6f 6e );. cgi_set_con
3600: 74 65 6e 74 5f 74 79 70 65 28 67 2e 7a 43 6f 6e tent_type(g.zCon
3610: 74 65 6e 74 54 79 70 65 29 3b 0a 20 20 62 6c 6f tentType);. blo
3620: 62 5f 7a 65 72 6f 28 26 78 66 65 72 2e 65 72 72 b_zero(&xfer.err
3630: 29 3b 0a 20 20 78 66 65 72 2e 70 49 6e 20 3d 20 );. xfer.pIn =
3640: 26 67 2e 63 67 69 49 6e 3b 0a 20 20 78 66 65 72 &g.cgiIn;. xfer
3650: 2e 70 4f 75 74 20 3d 20 63 67 69 5f 6f 75 74 70 .pOut = cgi_outp
3660: 75 74 5f 62 6c 6f 62 28 29 3b 0a 20 20 78 66 65 ut_blob();. xfe
3670: 72 2e 6d 78 53 65 6e 64 20 3d 20 64 62 5f 67 65 r.mxSend = db_ge
3680: 74 5f 69 6e 74 28 22 6d 61 78 2d 64 6f 77 6e 6c t_int("max-downl
3690: 6f 61 64 22 2c 20 35 30 30 30 30 30 30 29 3b 0a oad", 5000000);.
36a0: 0a 20 20 64 62 5f 62 65 67 69 6e 5f 74 72 61 6e . db_begin_tran
36b0: 73 61 63 74 69 6f 6e 28 29 3b 0a 20 20 64 62 5f saction();. db_
36c0: 6d 75 6c 74 69 5f 65 78 65 63 28 0a 20 20 20 20 multi_exec(.
36d0: 20 22 43 52 45 41 54 45 20 54 45 4d 50 20 54 41 "CREATE TEMP TA
36e0: 42 4c 45 20 6f 6e 72 65 6d 6f 74 65 28 72 69 64 BLE onremote(rid
36f0: 20 49 4e 54 45 47 45 52 20 50 52 49 4d 41 52 59 INTEGER PRIMARY
3700: 20 4b 45 59 29 3b 22 0a 20 20 29 3b 0a 20 20 77 KEY);". );. w
3710: 68 69 6c 65 28 20 62 6c 6f 62 5f 6c 69 6e 65 28 hile( blob_line(
3720: 78 66 65 72 2e 70 49 6e 2c 20 26 78 66 65 72 2e xfer.pIn, &xfer.
3730: 6c 69 6e 65 29 20 29 7b 0a 20 20 20 20 78 66 65 line) ){. xfe
3740: 72 2e 6e 54 6f 6b 65 6e 20 3d 20 62 6c 6f 62 5f r.nToken = blob_
3750: 74 6f 6b 65 6e 69 7a 65 28 26 78 66 65 72 2e 6c tokenize(&xfer.l
3760: 69 6e 65 2c 20 78 66 65 72 2e 61 54 6f 6b 65 6e ine, xfer.aToken
3770: 2c 20 63 6f 75 6e 74 28 78 66 65 72 2e 61 54 6f , count(xfer.aTo
3780: 6b 65 6e 29 29 3b 0a 0a 20 20 20 20 2f 2a 20 20 ken));.. /*
3790: 20 66 69 6c 65 20 55 55 49 44 20 53 49 5a 45 20 file UUID SIZE
37a0: 5c 6e 20 43 4f 4e 54 45 4e 54 0a 20 20 20 20 2a \n CONTENT. *
37b0: 2a 20 20 20 66 69 6c 65 20 55 55 49 44 20 44 45 * file UUID DE
37c0: 4c 54 41 53 52 43 20 53 49 5a 45 20 5c 6e 20 43 LTASRC SIZE \n C
37d0: 4f 4e 54 45 4e 54 0a 20 20 20 20 2a 2a 0a 20 20 ONTENT. **.
37e0: 20 20 2a 2a 20 41 63 63 65 70 74 20 61 20 66 69 ** Accept a fi
37f0: 6c 65 20 66 72 6f 6d 20 74 68 65 20 63 6c 69 65 le from the clie
3800: 6e 74 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 69 nt.. */. i
3810: 66 28 20 62 6c 6f 62 5f 65 71 28 26 78 66 65 72 f( blob_eq(&xfer
3820: 2e 61 54 6f 6b 65 6e 5b 30 5d 2c 20 22 66 69 6c .aToken[0], "fil
3830: 65 22 29 20 29 7b 0a 20 20 20 20 20 20 69 66 28 e") ){. if(
3840: 20 21 69 73 50 75 73 68 20 29 7b 0a 20 20 20 20 !isPush ){.
3850: 20 20 20 20 63 67 69 5f 72 65 73 65 74 5f 63 6f cgi_reset_co
3860: 6e 74 65 6e 74 28 29 3b 0a 20 20 20 20 20 20 20 ntent();.
3870: 20 40 20 65 72 72 6f 72 20 6e 6f 74 5c 73 61 75 @ error not\sau
3880: 74 68 6f 72 69 7a 65 64 5c 73 74 6f 5c 73 77 72 thorized\sto\swr
3890: 69 74 65 0a 20 20 20 20 20 20 20 20 6e 45 72 72 ite. nErr
38a0: 2b 2b 3b 0a 20 20 20 20 20 20 20 20 62 72 65 61 ++;. brea
38b0: 6b 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 20 k;. }.
38c0: 20 78 66 65 72 5f 61 63 63 65 70 74 5f 66 69 6c xfer_accept_fil
38d0: 65 28 26 78 66 65 72 29 3b 0a 20 20 20 20 20 20 e(&xfer);.
38e0: 69 66 28 20 62 6c 6f 62 5f 73 69 7a 65 28 26 78 if( blob_size(&x
38f0: 66 65 72 2e 65 72 72 29 20 29 7b 0a 20 20 20 20 fer.err) ){.
3900: 20 20 20 20 63 67 69 5f 72 65 73 65 74 5f 63 6f cgi_reset_co
3910: 6e 74 65 6e 74 28 29 3b 0a 20 20 20 20 20 20 20 ntent();.
3920: 20 40 20 65 72 72 6f 72 20 25 54 28 62 6c 6f 62 @ error %T(blob
3930: 5f 73 74 72 28 26 78 66 65 72 2e 65 72 72 29 29 _str(&xfer.err))
3940: 0a 20 20 20 20 20 20 20 20 6e 45 72 72 2b 2b 3b . nErr++;
3950: 0a 20 20 20 20 20 20 20 20 62 72 65 61 6b 3b 0a . break;.
3960: 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 65 6c 73 }. }els
3970: 65 0a 0a 20 20 20 20 2f 2a 20 20 20 67 69 6d 6d e.. /* gimm
3980: 65 20 55 55 49 44 0a 20 20 20 20 2a 2a 0a 20 20 e UUID. **.
3990: 20 20 2a 2a 20 43 6c 69 65 6e 74 20 69 73 20 72 ** Client is r
39a0: 65 71 75 65 73 74 69 6e 67 20 61 20 66 69 6c 65 equesting a file
39b0: 2e 20 20 53 65 6e 64 20 69 74 2e 0a 20 20 20 20 . Send it..
39c0: 2a 2f 0a 20 20 20 20 69 66 28 20 62 6c 6f 62 5f */. if( blob_
39d0: 65 71 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b eq(&xfer.aToken[
39e0: 30 5d 2c 20 22 67 69 6d 6d 65 22 29 0a 20 20 20 0], "gimme").
39f0: 20 20 26 26 20 78 66 65 72 2e 6e 54 6f 6b 65 6e && xfer.nToken
3a00: 3d 3d 32 0a 20 20 20 20 20 26 26 20 62 6c 6f 62 ==2. && blob
3a10: 5f 69 73 5f 75 75 69 64 28 26 78 66 65 72 2e 61 _is_uuid(&xfer.a
3a20: 54 6f 6b 65 6e 5b 31 5d 29 0a 20 20 20 20 29 7b Token[1]). ){
3a30: 0a 20 20 20 20 20 20 69 66 28 20 69 73 50 75 6c . if( isPul
3a40: 6c 20 29 7b 0a 20 20 20 20 20 20 20 20 69 6e 74 l ){. int
3a50: 20 72 69 64 20 3d 20 72 69 64 5f 66 72 6f 6d 5f rid = rid_from_
3a60: 75 75 69 64 28 26 78 66 65 72 2e 61 54 6f 6b 65 uuid(&xfer.aToke
3a70: 6e 5b 31 5d 2c 20 30 29 3b 0a 20 20 20 20 20 20 n[1], 0);.
3a80: 20 20 69 66 28 20 72 69 64 20 29 7b 0a 20 20 20 if( rid ){.
3a90: 20 20 20 20 20 20 20 73 65 6e 64 5f 66 69 6c 65 send_file
3aa0: 28 26 78 66 65 72 2c 20 72 69 64 2c 20 26 78 66 (&xfer, rid, &xf
3ab0: 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 2c 20 64 65 er.aToken[1], de
3ac0: 6c 74 61 46 6c 61 67 29 3b 0a 20 20 20 20 20 20 ltaFlag);.
3ad0: 20 20 7d 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 }. }.
3ae0: 7d 65 6c 73 65 0a 0a 20 20 20 20 2f 2a 20 20 20 }else.. /*
3af0: 69 67 6f 74 20 55 55 49 44 0a 20 20 20 20 2a 2a igot UUID. **
3b00: 0a 20 20 20 20 2a 2a 20 43 6c 69 65 6e 74 20 61 . ** Client a
3b10: 6e 6e 6f 75 6e 63 65 73 20 74 68 61 74 20 69 74 nnounces that it
3b20: 20 68 61 73 20 61 20 70 61 72 74 69 63 75 6c 61 has a particula
3b30: 72 20 66 69 6c 65 2e 0a 20 20 20 20 2a 2f 0a 20 r file.. */.
3b40: 20 20 20 69 66 28 20 78 66 65 72 2e 6e 54 6f 6b if( xfer.nTok
3b50: 65 6e 3d 3d 32 0a 20 20 20 20 20 26 26 20 62 6c en==2. && bl
3b60: 6f 62 5f 65 71 28 26 78 66 65 72 2e 61 54 6f 6b ob_eq(&xfer.aTok
3b70: 65 6e 5b 30 5d 2c 20 22 69 67 6f 74 22 29 0a 20 en[0], "igot").
3b80: 20 20 20 20 26 26 20 62 6c 6f 62 5f 69 73 5f 75 && blob_is_u
3b90: 75 69 64 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e uid(&xfer.aToken
3ba0: 5b 31 5d 29 0a 20 20 20 20 29 7b 0a 20 20 20 20 [1]). ){.
3bb0: 20 20 69 66 28 20 69 73 50 75 73 68 20 29 7b 0a if( isPush ){.
3bc0: 20 20 20 20 20 20 20 20 72 69 64 5f 66 72 6f 6d rid_from
3bd0: 5f 75 75 69 64 28 26 78 66 65 72 2e 61 54 6f 6b _uuid(&xfer.aTok
3be0: 65 6e 5b 31 5d 2c 20 31 29 3b 0a 20 20 20 20 20 en[1], 1);.
3bf0: 20 7d 0a 20 20 20 20 7d 65 6c 73 65 0a 20 20 0a }. }else. .
3c00: 20 20 20 20 0a 20 20 20 20 2f 2a 20 20 20 20 70 . /* p
3c10: 75 6c 6c 20 20 53 45 52 56 45 52 43 4f 44 45 20 ull SERVERCODE
3c20: 20 50 52 4f 4a 45 43 54 43 4f 44 45 0a 20 20 20 PROJECTCODE.
3c30: 20 2a 2a 20 20 20 20 70 75 73 68 20 20 53 45 52 ** push SER
3c40: 56 45 52 43 4f 44 45 20 20 50 52 4f 4a 45 43 54 VERCODE PROJECT
3c50: 43 4f 44 45 0a 20 20 20 20 2a 2a 0a 20 20 20 20 CODE. **.
3c60: 2a 2a 20 54 68 65 20 63 6c 69 65 6e 74 20 77 61 ** The client wa
3c70: 6e 74 73 20 65 69 74 68 65 72 20 73 65 6e 64 20 nts either send
3c80: 6f 72 20 72 65 63 65 69 76 65 2e 20 20 54 68 65 or receive. The
3c90: 20 73 65 72 76 65 72 20 73 68 6f 75 6c 64 0a 20 server should.
3ca0: 20 20 20 2a 2a 20 76 65 72 69 66 79 20 74 68 61 ** verify tha
3cb0: 74 20 74 68 65 20 70 72 6f 6a 65 63 74 20 63 6f t the project co
3cc0: 64 65 20 6d 61 74 63 68 65 73 20 61 6e 64 20 74 de matches and t
3cd0: 68 61 74 20 74 68 65 20 73 65 72 76 65 72 20 63 hat the server c
3ce0: 6f 64 65 0a 20 20 20 20 2a 2a 20 64 6f 65 73 20 ode. ** does
3cf0: 6e 6f 74 20 6d 61 74 63 68 2e 0a 20 20 20 20 2a not match.. *
3d00: 2f 0a 20 20 20 20 69 66 28 20 78 66 65 72 2e 6e /. if( xfer.n
3d10: 54 6f 6b 65 6e 3d 3d 33 0a 20 20 20 20 20 26 26 Token==3. &&
3d20: 20 28 62 6c 6f 62 5f 65 71 28 26 78 66 65 72 2e (blob_eq(&xfer.
3d30: 61 54 6f 6b 65 6e 5b 30 5d 2c 20 22 70 75 6c 6c aToken[0], "pull
3d40: 22 29 20 7c 7c 20 62 6c 6f 62 5f 65 71 28 26 78 ") || blob_eq(&x
3d50: 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d 2c 20 22 fer.aToken[0], "
3d60: 70 75 73 68 22 29 29 0a 20 20 20 20 20 26 26 20 push")). &&
3d70: 62 6c 6f 62 5f 69 73 5f 75 75 69 64 28 26 78 66 blob_is_uuid(&xf
3d80: 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 29 0a 20 20 er.aToken[1]).
3d90: 20 20 20 26 26 20 62 6c 6f 62 5f 69 73 5f 75 75 && blob_is_uu
3da0: 69 64 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b id(&xfer.aToken[
3db0: 32 5d 29 0a 20 20 20 20 29 7b 0a 20 20 20 20 20 2]). ){.
3dc0: 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 53 43 const char *zSC
3dd0: 6f 64 65 3b 0a 20 20 20 20 20 20 63 6f 6e 73 74 ode;. const
3de0: 20 63 68 61 72 20 2a 7a 50 43 6f 64 65 3b 0a 0a char *zPCode;..
3df0: 20 20 20 20 20 20 7a 53 43 6f 64 65 20 3d 20 64 zSCode = d
3e00: 62 5f 67 65 74 28 22 73 65 72 76 65 72 2d 63 6f b_get("server-co
3e10: 64 65 22 2c 20 30 29 3b 0a 20 20 20 20 20 20 69 de", 0);. i
3e20: 66 28 20 7a 53 43 6f 64 65 3d 3d 30 20 29 7b 0a f( zSCode==0 ){.
3e30: 20 20 20 20 20 20 20 20 66 6f 73 73 69 6c 5f 70 fossil_p
3e40: 61 6e 69 63 28 22 6d 69 73 73 69 6e 67 20 73 65 anic("missing se
3e50: 72 76 65 72 20 63 6f 64 65 22 29 3b 0a 20 20 20 rver code");.
3e60: 20 20 20 7d 0a 20 20 20 20 20 20 69 66 28 20 62 }. if( b
3e70: 6c 6f 62 5f 65 71 5f 73 74 72 28 26 78 66 65 72 lob_eq_str(&xfer
3e80: 2e 61 54 6f 6b 65 6e 5b 31 5d 2c 20 7a 53 43 6f .aToken[1], zSCo
3e90: 64 65 2c 20 2d 31 29 20 29 7b 0a 20 20 20 20 20 de, -1) ){.
3ea0: 20 20 20 63 67 69 5f 72 65 73 65 74 5f 63 6f 6e cgi_reset_con
3eb0: 74 65 6e 74 28 29 3b 0a 20 20 20 20 20 20 20 20 tent();.
3ec0: 40 20 65 72 72 6f 72 20 73 65 72 76 65 72 5c 73 @ error server\s
3ed0: 6c 6f 6f 70 0a 20 20 20 20 20 20 20 20 6e 45 72 loop. nEr
3ee0: 72 2b 2b 3b 0a 20 20 20 20 20 20 20 20 62 72 65 r++;. bre
3ef0: 61 6b 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 ak;. }.
3f00: 20 20 7a 50 43 6f 64 65 20 3d 20 64 62 5f 67 65 zPCode = db_ge
3f10: 74 28 22 70 72 6f 6a 65 63 74 2d 63 6f 64 65 22 t("project-code"
3f20: 2c 20 30 29 3b 0a 20 20 20 20 20 20 69 66 28 20 , 0);. if(
3f30: 7a 50 43 6f 64 65 3d 3d 30 20 29 7b 0a 20 20 20 zPCode==0 ){.
3f40: 20 20 20 20 20 66 6f 73 73 69 6c 5f 70 61 6e 69 fossil_pani
3f50: 63 28 22 6d 69 73 73 69 6e 67 20 70 72 6f 6a 65 c("missing proje
3f60: 63 74 20 63 6f 64 65 22 29 3b 0a 20 20 20 20 20 ct code");.
3f70: 20 7d 0a 20 20 20 20 20 20 69 66 28 20 21 62 6c }. if( !bl
3f80: 6f 62 5f 65 71 5f 73 74 72 28 26 78 66 65 72 2e ob_eq_str(&xfer.
3f90: 61 54 6f 6b 65 6e 5b 32 5d 2c 20 7a 50 43 6f 64 aToken[2], zPCod
3fa0: 65 2c 20 2d 31 29 20 29 7b 0a 20 20 20 20 20 20 e, -1) ){.
3fb0: 20 20 63 67 69 5f 72 65 73 65 74 5f 63 6f 6e 74 cgi_reset_cont
3fc0: 65 6e 74 28 29 3b 0a 20 20 20 20 20 20 20 20 40 ent();. @
3fd0: 20 65 72 72 6f 72 20 77 72 6f 6e 67 5c 73 70 72 error wrong\spr
3fe0: 6f 6a 65 63 74 0a 20 20 20 20 20 20 20 20 6e 45 oject. nE
3ff0: 72 72 2b 2b 3b 0a 20 20 20 20 20 20 20 20 62 72 rr++;. br
4000: 65 61 6b 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 eak;. }.
4010: 20 20 20 6c 6f 67 69 6e 5f 63 68 65 63 6b 5f 63 login_check_c
4020: 72 65 64 65 6e 74 69 61 6c 73 28 29 3b 0a 20 20 redentials();.
4030: 20 20 20 20 69 66 28 20 62 6c 6f 62 5f 65 71 28 if( blob_eq(
4040: 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d 2c &xfer.aToken[0],
4050: 20 22 70 75 6c 6c 22 29 20 29 7b 0a 20 20 20 20 "pull") ){.
4060: 20 20 20 20 69 66 28 20 21 67 2e 6f 6b 52 65 61 if( !g.okRea
4070: 64 20 29 7b 0a 20 20 20 20 20 20 20 20 20 20 63 d ){. c
4080: 67 69 5f 72 65 73 65 74 5f 63 6f 6e 74 65 6e 74 gi_reset_content
4090: 28 29 3b 0a 20 20 20 20 20 20 20 20 20 20 40 20 ();. @
40a0: 65 72 72 6f 72 20 6e 6f 74 5c 73 61 75 74 68 6f error not\sautho
40b0: 72 69 7a 65 64 5c 73 74 6f 5c 73 72 65 61 64 0a rized\sto\sread.
40c0: 20 20 20 20 20 20 20 20 20 20 6e 45 72 72 2b 2b nErr++
40d0: 3b 0a 20 20 20 20 20 20 20 20 20 20 62 72 65 61 ;. brea
40e0: 6b 3b 0a 20 20 20 20 20 20 20 20 7d 0a 20 20 20 k;. }.
40f0: 20 20 20 20 20 69 73 50 75 6c 6c 20 3d 20 31 3b isPull = 1;
4100: 0a 20 20 20 20 20 20 7d 65 6c 73 65 7b 0a 20 20 . }else{.
4110: 20 20 20 20 20 20 69 66 28 20 21 67 2e 6f 6b 57 if( !g.okW
4120: 72 69 74 65 20 29 7b 0a 20 20 20 20 20 20 20 20 rite ){.
4130: 20 20 69 66 28 20 21 69 73 50 75 6c 6c 20 29 7b if( !isPull ){
4140: 0a 20 20 20 20 20 20 20 20 20 20 20 20 63 67 69 . cgi
4150: 5f 72 65 73 65 74 5f 63 6f 6e 74 65 6e 74 28 29 _reset_content()
4160: 3b 0a 20 20 20 20 20 20 20 20 20 20 20 20 40 20 ;. @
4170: 65 72 72 6f 72 20 6e 6f 74 5c 73 61 75 74 68 6f error not\sautho
4180: 72 69 7a 65 64 5c 73 74 6f 5c 73 77 72 69 74 65 rized\sto\swrite
4190: 0a 20 20 20 20 20 20 20 20 20 20 20 20 6e 45 72 . nEr
41a0: 72 2b 2b 3b 0a 20 20 20 20 20 20 20 20 20 20 7d r++;. }
41b0: 65 6c 73 65 7b 0a 20 20 20 20 20 20 20 20 20 20 else{.
41c0: 20 20 40 20 6d 65 73 73 61 67 65 20 70 75 6c 6c @ message pull
41d0: 5c 73 6f 6e 6c 79 5c 73 2d 5c 73 6e 6f 74 5c 73 \sonly\s-\snot\s
41e0: 61 75 74 68 6f 72 69 7a 65 64 5c 73 74 6f 5c 73 authorized\sto\s
41f0: 70 75 73 68 0a 20 20 20 20 20 20 20 20 20 20 7d push. }
4200: 0a 20 20 20 20 20 20 20 20 7d 65 6c 73 65 7b 0a . }else{.
4210: 20 20 20 20 20 20 20 20 20 20 69 73 50 75 73 68 isPush
4220: 20 3d 20 31 3b 0a 20 20 20 20 20 20 20 20 7d 0a = 1;. }.
4230: 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 65 6c 73 }. }els
4240: 65 0a 0a 20 20 20 20 2f 2a 20 20 20 20 63 6c 6f e.. /* clo
4250: 6e 65 0a 20 20 20 20 2a 2a 0a 20 20 20 20 2a 2a ne. **. **
4260: 20 54 68 65 20 63 6c 69 65 6e 74 20 6b 6e 6f 77 The client know
4270: 73 20 6e 6f 74 68 69 6e 67 2e 20 20 54 65 6c 6c s nothing. Tell
4280: 20 61 6c 6c 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 all.. */.
4290: 20 69 66 28 20 62 6c 6f 62 5f 65 71 28 26 78 66 if( blob_eq(&xf
42a0: 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d 2c 20 22 63 er.aToken[0], "c
42b0: 6c 6f 6e 65 22 29 20 29 7b 0a 20 20 20 20 20 20 lone") ){.
42c0: 6c 6f 67 69 6e 5f 63 68 65 63 6b 5f 63 72 65 64 login_check_cred
42d0: 65 6e 74 69 61 6c 73 28 29 3b 0a 20 20 20 20 20 entials();.
42e0: 20 69 66 28 20 21 67 2e 6f 6b 43 6c 6f 6e 65 20 if( !g.okClone
42f0: 29 7b 0a 20 20 20 20 20 20 20 20 63 67 69 5f 72 ){. cgi_r
4300: 65 73 65 74 5f 63 6f 6e 74 65 6e 74 28 29 3b 0a eset_content();.
4310: 20 20 20 20 20 20 20 20 40 20 65 72 72 6f 72 20 @ error
4320: 6e 6f 74 5c 73 61 75 74 68 6f 72 69 7a 65 64 5c not\sauthorized\
4330: 73 74 6f 5c 73 63 6c 6f 6e 65 0a 20 20 20 20 20 sto\sclone.
4340: 20 20 20 6e 45 72 72 2b 2b 3b 0a 20 20 20 20 20 nErr++;.
4350: 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20 break;.
4360: 7d 0a 20 20 20 20 20 20 69 73 50 75 6c 6c 20 3d }. isPull =
4370: 20 31 3b 0a 20 20 20 20 20 20 64 65 6c 74 61 46 1;. deltaF
4380: 6c 61 67 20 3d 20 31 3b 0a 20 20 20 20 20 20 40 lag = 1;. @
4390: 20 70 75 73 68 20 25 73 28 64 62 5f 67 65 74 28 push %s(db_get(
43a0: 22 73 65 72 76 65 72 2d 63 6f 64 65 22 2c 20 22 "server-code", "
43b0: 78 22 29 29 20 25 73 28 64 62 5f 67 65 74 28 22 x")) %s(db_get("
43c0: 70 72 6f 6a 65 63 74 2d 63 6f 64 65 22 2c 20 22 project-code", "
43d0: 78 22 29 29 0a 20 20 20 20 7d 65 6c 73 65 0a 0a x")). }else..
43e0: 20 20 20 20 2f 2a 20 20 20 20 6c 6f 67 69 6e 20 /* login
43f0: 20 55 53 45 52 20 20 4e 4f 4e 43 45 20 20 53 49 USER NONCE SI
4400: 47 4e 41 54 55 52 45 0a 20 20 20 20 2a 2a 0a 20 GNATURE. **.
4410: 20 20 20 2a 2a 20 43 68 65 63 6b 20 66 6f 72 20 ** Check for
4420: 61 20 76 61 6c 69 64 20 6c 6f 67 69 6e 2e 20 20 a valid login.
4430: 54 68 69 73 20 68 61 73 20 74 6f 20 68 61 70 70 This has to happ
4440: 65 6e 20 62 65 66 6f 72 65 20 61 6e 79 74 68 69 en before anythi
4450: 6e 67 20 65 6c 73 65 2e 0a 20 20 20 20 2a 2a 20 ng else.. **
4460: 54 68 65 20 63 6c 69 65 6e 74 20 63 61 6e 20 73 The client can s
4470: 65 6e 64 20 6d 75 6c 74 69 70 6c 65 20 6c 6f 67 end multiple log
4480: 69 6e 73 2e 20 20 50 65 72 6d 69 73 73 69 6f 6e ins. Permission
4490: 73 20 61 72 65 20 63 75 6d 75 6c 61 74 69 76 65 s are cumulative
44a0: 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 69 66 28 .. */. if(
44b0: 20 62 6c 6f 62 5f 65 71 28 26 78 66 65 72 2e 61 blob_eq(&xfer.a
44c0: 54 6f 6b 65 6e 5b 30 5d 2c 20 22 6c 6f 67 69 6e Token[0], "login
44d0: 22 29 0a 20 20 20 20 20 26 26 20 78 66 65 72 2e "). && xfer.
44e0: 6e 54 6f 6b 65 6e 3d 3d 34 0a 20 20 20 20 29 7b nToken==4. ){
44f0: 0a 20 20 20 20 20 20 69 66 28 20 64 69 73 61 62 . if( disab
4500: 6c 65 4c 6f 67 69 6e 20 29 7b 0a 20 20 20 20 20 leLogin ){.
4510: 20 20 20 67 2e 6f 6b 52 65 61 64 20 3d 20 67 2e g.okRead = g.
4520: 6f 6b 57 72 69 74 65 20 3d 20 31 3b 0a 20 20 20 okWrite = 1;.
4530: 20 20 20 7d 65 6c 73 65 20 69 66 28 20 63 68 65 }else if( che
4540: 63 6b 5f 74 61 69 6c 5f 68 61 73 68 28 26 78 66 ck_tail_hash(&xf
4550: 65 72 2e 61 54 6f 6b 65 6e 5b 32 5d 2c 20 78 66 er.aToken[2], xf
4560: 65 72 2e 70 49 6e 29 20 29 7b 0a 20 20 20 20 20 er.pIn) ){.
4570: 20 20 20 63 68 65 63 6b 5f 6c 6f 67 69 6e 28 26 check_login(&
4580: 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 2c 20 xfer.aToken[1],
4590: 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 32 5d 2c &xfer.aToken[2],
45a0: 20 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 33 5d &xfer.aToken[3]
45b0: 29 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 7d );. }. }
45c0: 65 6c 73 65 0a 20 20 20 20 0a 20 20 20 20 2f 2a else. . /*
45d0: 20 20 20 20 63 6f 6f 6b 69 65 20 54 45 58 54 0a cookie TEXT.
45e0: 20 20 20 20 2a 2a 0a 20 20 20 20 2a 2a 20 41 20 **. ** A
45f0: 63 6f 6f 6b 69 65 20 63 6f 6e 74 61 69 6e 73 20 cookie contains
4600: 61 20 61 72 62 69 74 72 61 72 79 2d 6c 65 6e 67 a arbitrary-leng
4610: 74 68 20 61 72 67 75 6d 65 6e 74 20 74 68 61 74 th argument that
4620: 20 69 73 20 73 65 72 76 65 72 2d 64 65 66 69 6e is server-defin
4630: 65 64 2e 0a 20 20 20 20 2a 2a 20 54 68 65 20 61 ed.. ** The a
4640: 72 67 75 6d 65 6e 74 20 6d 75 73 74 20 62 65 20 rgument must be
4650: 65 6e 63 6f 64 65 64 20 73 6f 20 61 73 20 6e 6f encoded so as no
4660: 74 20 74 6f 20 63 6f 6e 74 61 69 6e 20 61 6e 79 t to contain any
4670: 20 77 68 69 74 65 73 70 61 63 65 2e 0a 20 20 20 whitespace..
4680: 20 2a 2a 20 54 68 65 20 73 65 72 76 65 72 20 63 ** The server c
4690: 61 6e 20 6f 70 74 69 6f 6e 61 6c 6c 79 20 73 65 an optionally se
46a0: 6e 64 20 61 20 63 6f 6f 6b 69 65 20 74 6f 20 74 nd a cookie to t
46b0: 68 65 20 63 6c 69 65 6e 74 2e 20 20 54 68 65 20 he client. The
46c0: 63 6c 69 65 6e 74 0a 20 20 20 20 2a 2a 20 6d 69 client. ** mi
46d0: 67 68 74 20 74 68 65 6e 20 72 65 74 75 72 6e 20 ght then return
46e0: 74 68 65 20 73 61 6d 65 20 63 6f 6f 6b 69 65 20 the same cookie
46f0: 62 61 63 6b 20 74 6f 20 74 68 65 20 73 65 72 76 back to the serv
4700: 65 72 20 6f 6e 20 69 74 73 20 6e 65 78 74 0a 20 er on its next.
4710: 20 20 20 2a 2a 20 63 6f 6d 6d 75 6e 69 63 61 74 ** communicat
4720: 69 6f 6e 2e 20 20 54 68 65 20 63 6f 6f 6b 69 65 ion. The cookie
4730: 20 6d 69 67 68 74 20 72 65 63 6f 72 64 20 69 6e might record in
4740: 66 6f 72 6d 61 74 69 6f 6e 20 74 68 61 74 20 68 formation that h
4750: 65 6c 70 73 0a 20 20 20 20 2a 2a 20 74 68 65 20 elps. ** the
4760: 73 65 72 76 65 72 20 6f 70 74 69 6d 69 7a 65 20 server optimize
4770: 61 20 70 75 73 68 20 6f 72 20 70 75 6c 6c 2e 0a a push or pull..
4780: 20 20 20 20 2a 2a 0a 20 20 20 20 2a 2a 20 54 68 **. ** Th
4790: 65 20 63 6c 69 65 6e 74 20 69 73 20 6e 6f 74 20 e client is not
47a0: 72 65 71 75 69 72 65 64 20 74 6f 20 72 65 74 75 required to retu
47b0: 72 6e 20 61 20 63 6f 6f 6b 69 65 2e 20 20 53 6f rn a cookie. So
47c0: 20 74 68 65 20 73 65 72 76 65 72 0a 20 20 20 20 the server.
47d0: 2a 2a 20 6d 75 73 74 20 6e 6f 74 20 64 65 70 65 ** must not depe
47e0: 6e 64 20 6f 6e 20 74 68 65 20 63 6f 6f 6b 69 65 nd on the cookie
47f0: 2e 20 20 54 68 65 20 63 6f 6f 6b 69 65 20 73 68 . The cookie sh
4800: 6f 75 6c 64 20 62 65 20 61 6e 20 6f 70 74 69 6d ould be an optim
4810: 69 7a 61 74 69 6f 6e 0a 20 20 20 20 2a 2a 20 6f ization. ** o
4820: 6e 6c 79 2e 20 20 54 68 65 20 63 6c 69 65 6e 74 nly. The client
4830: 20 6d 69 67 68 74 20 61 6c 73 6f 20 73 65 6e 64 might also send
4840: 20 61 20 63 6f 6f 6b 69 65 20 74 68 61 74 20 63 a cookie that c
4850: 61 6d 65 20 66 72 6f 6d 20 61 20 64 69 66 66 65 ame from a diffe
4860: 72 65 6e 74 0a 20 20 20 20 2a 2a 20 73 65 72 76 rent. ** serv
4870: 65 72 2e 20 20 53 6f 20 74 68 65 20 73 65 72 76 er. So the serv
4880: 65 72 20 6d 75 73 74 20 62 65 20 70 72 65 70 61 er must be prepa
4890: 72 65 64 20 74 6f 20 64 69 73 74 69 6e 67 75 69 red to distingui
48a0: 73 68 20 69 74 73 20 6f 77 6e 20 63 6f 6f 6b 69 sh its own cooki
48b0: 65 0a 20 20 20 20 2a 2a 20 66 72 6f 6d 20 63 6f e. ** from co
48c0: 6f 6b 69 65 73 20 6f 72 69 67 69 6e 61 74 69 6e okies originatin
48d0: 67 20 66 72 6f 6d 20 6f 74 68 65 72 20 73 65 72 g from other ser
48e0: 76 65 72 73 2e 20 20 54 68 65 20 63 6c 69 65 6e vers. The clien
48f0: 74 20 6d 69 67 68 74 20 73 65 6e 64 0a 20 20 20 t might send.
4900: 20 2a 2a 20 62 61 63 6b 20 73 65 76 65 72 61 6c ** back several
4910: 20 64 69 66 66 65 72 65 6e 74 20 63 6f 6f 6b 69 different cooki
4920: 65 73 20 74 6f 20 74 68 65 20 73 65 72 76 65 72 es to the server
4930: 2e 20 20 54 68 65 20 73 65 72 76 65 72 20 73 68 . The server sh
4940: 6f 75 6c 64 20 62 65 0a 20 20 20 20 2a 2a 20 70 ould be. ** p
4950: 72 65 70 61 72 65 64 20 74 6f 20 73 69 66 74 20 repared to sift
4960: 74 68 72 6f 75 67 68 20 74 68 65 20 63 6f 6f 6b through the cook
4970: 69 65 73 20 61 6e 64 20 70 69 63 6b 20 74 68 65 ies and pick the
4980: 20 6f 6e 65 20 74 68 61 74 20 69 74 20 77 61 6e one that it wan
4990: 74 73 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 69 ts.. */. i
49a0: 66 28 20 62 6c 6f 62 5f 65 71 28 26 78 66 65 72 f( blob_eq(&xfer
49b0: 2e 61 54 6f 6b 65 6e 5b 30 5d 2c 20 22 63 6f 6f .aToken[0], "coo
49c0: 6b 69 65 22 29 20 26 26 20 78 66 65 72 2e 6e 54 kie") && xfer.nT
49d0: 6f 6b 65 6e 3d 3d 32 20 29 7b 0a 20 20 20 20 20 oken==2 ){.
49e0: 20 2f 2a 20 50 72 6f 63 65 73 73 20 74 68 65 20 /* Process the
49f0: 63 6f 6f 6b 69 65 20 2a 2f 0a 20 20 20 20 7d 65 cookie */. }e
4a00: 6c 73 65 0a 0a 20 20 20 20 2f 2a 20 55 6e 6b 6e lse.. /* Unkn
4a10: 6f 77 6e 20 6d 65 73 73 61 67 65 0a 20 20 20 20 own message.
4a20: 2a 2f 0a 20 20 20 20 7b 0a 20 20 20 20 20 20 63 */. {. c
4a30: 67 69 5f 72 65 73 65 74 5f 63 6f 6e 74 65 6e 74 gi_reset_content
4a40: 28 29 3b 0a 20 20 20 20 20 20 40 20 65 72 72 6f ();. @ erro
4a50: 72 20 62 61 64 5c 73 63 6f 6d 6d 61 6e 64 3a 5c r bad\scommand:\
4a60: 73 25 46 28 62 6c 6f 62 5f 73 74 72 28 26 78 66 s%F(blob_str(&xf
4a70: 65 72 2e 6c 69 6e 65 29 29 0a 20 20 20 20 7d 0a er.line)). }.
4a80: 20 20 20 20 62 6c 6f 62 61 72 72 61 79 5f 72 65 blobarray_re
4a90: 73 65 74 28 78 66 65 72 2e 61 54 6f 6b 65 6e 2c set(xfer.aToken,
4aa0: 20 78 66 65 72 2e 6e 54 6f 6b 65 6e 29 3b 0a 20 xfer.nToken);.
4ab0: 20 7d 0a 20 20 69 66 28 20 69 73 50 75 73 68 20 }. if( isPush
4ac0: 29 7b 0a 20 20 20 20 72 65 71 75 65 73 74 5f 70 ){. request_p
4ad0: 68 61 6e 74 6f 6d 73 28 26 78 66 65 72 2c 20 35 hantoms(&xfer, 5
4ae0: 30 30 29 3b 0a 20 20 7d 0a 20 20 69 66 28 20 69 00);. }. if( i
4af0: 73 50 75 6c 6c 20 29 7b 0a 20 20 20 20 63 72 65 sPull ){. cre
4b00: 61 74 65 5f 63 6c 75 73 74 65 72 28 29 3b 0a 20 ate_cluster();.
4b10: 20 20 20 73 65 6e 64 5f 75 6e 63 6c 75 73 74 65 send_uncluste
4b20: 72 65 64 28 26 78 66 65 72 29 3b 0a 20 20 7d 0a red(&xfer);. }.
4b30: 20 20 64 62 5f 65 6e 64 5f 74 72 61 6e 73 61 63 db_end_transac
4b40: 74 69 6f 6e 28 30 29 3b 0a 7d 0a 0a 2f 2a 0a 2a tion(0);.}../*.*
4b50: 2a 20 43 4f 4d 4d 41 4e 44 3a 20 74 65 73 74 2d * COMMAND: test-
4b60: 78 66 65 72 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 xfer.**.** This
4b70: 63 6f 6d 6d 61 6e 64 20 69 73 20 75 73 65 64 20 command is used
4b80: 66 6f 72 20 64 65 62 75 67 67 69 6e 67 20 74 68 for debugging th
4b90: 65 20 73 65 72 76 65 72 2e 20 20 54 68 65 72 65 e server. There
4ba0: 20 69 73 20 61 20 73 69 6e 67 6c 65 0a 2a 2a 20 is a single.**
4bb0: 61 72 67 75 6d 65 6e 74 20 77 68 69 63 68 20 69 argument which i
4bc0: 73 20 74 68 65 20 75 6e 63 6f 6d 70 72 65 73 73 s the uncompress
4bd0: 65 64 20 63 6f 6e 74 65 6e 74 20 6f 66 20 61 6e ed content of an
4be0: 20 22 78 66 65 72 22 20 6d 65 73 73 61 67 65 0a "xfer" message.
4bf0: 2a 2a 20 66 72 6f 6d 20 63 6c 69 65 6e 74 20 74 ** from client t
4c00: 6f 20 73 65 72 76 65 72 2e 20 20 54 68 69 73 20 o server. This
4c10: 63 6f 6d 6d 61 6e 64 20 69 6e 74 65 72 70 72 65 command interpre
4c20: 74 73 20 74 68 61 74 20 6d 65 73 73 61 67 65 20 ts that message
4c30: 61 73 0a 2a 2a 20 69 66 20 68 61 64 20 62 65 65 as.** if had bee
4c40: 6e 20 72 65 63 65 69 76 65 64 20 62 79 20 74 68 n received by th
4c50: 65 20 73 65 72 76 65 72 2e 0a 2a 2a 0a 2a 2a 20 e server..**.**
4c60: 4f 6e 20 74 68 65 20 63 6c 69 65 6e 74 20 73 69 On the client si
4c70: 64 65 2c 20 72 75 6e 3a 0a 2a 2a 0a 2a 2a 20 20 de, run:.**.**
4c80: 20 20 20 20 66 6f 73 73 69 6c 20 70 75 73 68 20 fossil push
4c90: 68 74 74 70 3a 2f 2f 62 6f 67 75 73 2f 20 2d 2d http://bogus/ --
4ca0: 68 74 74 70 74 72 61 63 65 0a 2a 2a 0a 2a 2a 20 httptrace.**.**
4cb0: 4f 72 20 61 20 73 69 6d 69 6c 61 72 20 63 6f 6d Or a similar com
4cc0: 6d 61 6e 64 20 74 6f 20 70 72 6f 76 69 64 65 20 mand to provide
4cd0: 74 68 65 20 6f 75 74 70 75 74 2e 20 20 54 68 65 the output. The
4ce0: 20 63 6f 6e 74 65 6e 74 20 6f 66 20 74 68 65 0a content of the.
4cf0: 2a 2a 20 6d 65 73 73 61 67 65 20 77 69 6c 6c 20 ** message will
4d00: 61 70 70 65 61 72 20 6f 6e 20 73 74 61 6e 64 61 appear on standa
4d10: 72 64 20 6f 75 74 70 75 74 2e 20 20 43 61 70 74 rd output. Capt
4d20: 75 72 65 20 74 68 69 73 20 6d 65 73 73 61 67 65 ure this message
4d30: 0a 2a 2a 20 69 6e 74 6f 20 61 20 66 69 6c 65 20 .** into a file
4d40: 6e 61 6d 65 64 20 28 66 6f 72 20 65 78 61 6d 70 named (for examp
4d50: 6c 65 29 20 6f 75 74 2e 74 78 74 2e 20 20 54 68 le) out.txt. Th
4d60: 65 6e 20 72 75 6e 20 74 68 65 0a 2a 2a 20 73 65 en run the.** se
4d70: 72 76 65 72 20 69 6e 20 67 64 62 3a 0a 2a 2a 0a rver in gdb:.**.
4d80: 2a 2a 20 20 20 20 20 67 64 62 20 66 6f 73 73 69 ** gdb fossi
4d90: 6c 0a 2a 2a 20 20 20 20 20 72 20 74 65 73 74 2d l.** r test-
4da0: 78 66 65 72 20 6f 75 74 2e 74 78 74 0a 2a 2f 0a xfer out.txt.*/.
4db0: 76 6f 69 64 20 63 6d 64 5f 74 65 73 74 5f 78 66 void cmd_test_xf
4dc0: 65 72 28 76 6f 69 64 29 7b 0a 20 20 69 6e 74 20 er(void){. int
4dd0: 6e 6f 74 55 73 65 64 3b 0a 20 20 69 66 28 20 67 notUsed;. if( g
4de0: 2e 61 72 67 63 21 3d 32 20 26 26 20 67 2e 61 72 .argc!=2 && g.ar
4df0: 67 63 21 3d 33 20 29 7b 0a 20 20 20 20 75 73 61 gc!=3 ){. usa
4e00: 67 65 28 22 3f 4d 45 53 53 41 47 45 46 49 4c 45 ge("?MESSAGEFILE
4e10: 3f 22 29 3b 0a 20 20 7d 0a 20 20 64 62 5f 6d 75 ?");. }. db_mu
4e20: 73 74 5f 62 65 5f 77 69 74 68 69 6e 5f 74 72 65 st_be_within_tre
4e30: 65 28 29 3b 0a 20 20 62 6c 6f 62 5f 7a 65 72 6f e();. blob_zero
4e40: 28 26 67 2e 63 67 69 49 6e 29 3b 0a 20 20 62 6c (&g.cgiIn);. bl
4e50: 6f 62 5f 72 65 61 64 5f 66 72 6f 6d 5f 66 69 6c ob_read_from_fil
4e60: 65 28 26 67 2e 63 67 69 49 6e 2c 20 67 2e 61 72 e(&g.cgiIn, g.ar
4e70: 67 63 3d 3d 32 20 3f 20 22 2d 22 20 3a 20 67 2e gc==2 ? "-" : g.
4e80: 61 72 67 76 5b 32 5d 29 3b 0a 20 20 64 69 73 61 argv[2]);. disa
4e90: 62 6c 65 4c 6f 67 69 6e 20 3d 20 31 3b 0a 20 20 bleLogin = 1;.
4ea0: 70 61 67 65 5f 78 66 65 72 28 29 3b 0a 20 20 70 page_xfer();. p
4eb0: 72 69 6e 74 66 28 22 25 73 5c 6e 22 2c 20 63 67 rintf("%s\n", cg
4ec0: 69 5f 65 78 74 72 61 63 74 5f 63 6f 6e 74 65 6e i_extract_conten
4ed0: 74 28 26 6e 6f 74 55 73 65 64 29 29 3b 0a 7d 0a t(¬Used));.}.
4ee0: 0a 0a 2f 2a 0a 2a 2a 20 53 79 6e 63 20 74 6f 20 ../*.** Sync to
4ef0: 74 68 65 20 68 6f 73 74 20 69 64 65 6e 74 69 66 the host identif
4f00: 69 65 64 20 69 6e 20 67 2e 75 72 6c 4e 61 6d 65 ied in g.urlName
4f10: 20 61 6e 64 20 67 2e 75 72 6c 50 61 74 68 2e 20 and g.urlPath.
4f20: 20 54 68 69 73 0a 2a 2a 20 72 6f 75 74 69 6e 65 This.** routine
4f30: 20 69 73 20 63 61 6c 6c 65 64 20 62 79 20 74 68 is called by th
4f40: 65 20 63 6c 69 65 6e 74 2e 0a 2a 2a 0a 2a 2a 20 e client..**.**
4f50: 52 65 63 6f 72 64 73 20 61 72 65 20 70 75 73 68 Records are push
4f60: 65 64 20 74 6f 20 74 68 65 20 73 65 72 76 65 72 ed to the server
4f70: 20 69 66 20 70 75 73 68 46 6c 61 67 20 69 73 20 if pushFlag is
4f80: 74 72 75 65 2e 20 20 52 65 63 6f 72 64 73 0a 2a true. Records.*
4f90: 2a 20 61 72 65 20 70 75 6c 6c 65 64 20 69 66 20 * are pulled if
4fa0: 70 75 6c 6c 46 6c 61 67 20 69 73 20 74 72 75 65 pullFlag is true
4fb0: 2e 20 20 41 20 66 75 6c 6c 20 73 79 6e 63 20 6f . A full sync o
4fc0: 63 63 75 72 73 20 69 66 20 62 6f 74 68 20 61 72 ccurs if both ar
4fd0: 65 0a 2a 2a 20 74 72 75 65 2e 0a 2a 2f 0a 76 6f e.** true..*/.vo
4fe0: 69 64 20 63 6c 69 65 6e 74 5f 73 79 6e 63 28 69 id client_sync(i
4ff0: 6e 74 20 70 75 73 68 46 6c 61 67 2c 20 69 6e 74 nt pushFlag, int
5000: 20 70 75 6c 6c 46 6c 61 67 2c 20 69 6e 74 20 63 pullFlag, int c
5010: 6c 6f 6e 65 46 6c 61 67 29 7b 0a 20 20 69 6e 74 loneFlag){. int
5020: 20 67 6f 20 3d 20 31 3b 20 20 20 20 20 20 20 20 go = 1;
5030: 2f 2a 20 4c 6f 6f 70 20 75 6e 74 69 6c 20 7a 65 /* Loop until ze
5040: 72 6f 20 2a 2f 0a 20 20 63 6f 6e 73 74 20 63 68 ro */. const ch
5050: 61 72 20 2a 7a 53 43 6f 64 65 20 3d 20 64 62 5f ar *zSCode = db_
5060: 67 65 74 28 22 73 65 72 76 65 72 2d 63 6f 64 65 get("server-code
5070: 22 2c 20 22 78 22 29 3b 0a 20 20 63 6f 6e 73 74 ", "x");. const
5080: 20 63 68 61 72 20 2a 7a 50 43 6f 64 65 20 3d 20 char *zPCode =
5090: 64 62 5f 67 65 74 28 22 70 72 6f 6a 65 63 74 2d db_get("project-
50a0: 63 6f 64 65 22 2c 20 30 29 3b 0a 20 20 69 6e 74 code", 0);. int
50b0: 20 6e 4d 73 67 20 3d 20 30 3b 20 20 20 20 20 20 nMsg = 0;
50c0: 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 20 6f 66 /* Number of
50d0: 20 6d 65 73 73 61 67 65 73 20 73 65 6e 74 20 6f messages sent o
50e0: 72 20 72 65 63 65 69 76 65 64 20 2a 2f 0a 20 20 r received */.
50f0: 69 6e 74 20 6e 43 79 63 6c 65 20 3d 20 30 3b 20 int nCycle = 0;
5100: 20 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 /* Number
5110: 20 6f 66 20 72 6f 75 6e 64 20 74 72 69 70 73 20 of round trips
5120: 74 6f 20 74 68 65 20 73 65 72 76 65 72 20 2a 2f to the server */
5130: 0a 20 20 69 6e 74 20 6e 46 69 6c 65 53 65 6e 64 . int nFileSend
5140: 20 3d 20 30 3b 0a 20 20 69 6e 74 20 6e 46 69 6c = 0;. int nFil
5150: 65 52 65 63 76 3b 20 20 20 20 20 20 20 20 20 20 eRecv;
5160: 2f 2a 20 4e 75 6d 62 65 72 20 6f 66 20 66 69 6c /* Number of fil
5170: 65 73 20 72 65 63 65 69 76 65 64 20 2a 2f 0a 20 es received */.
5180: 20 69 6e 74 20 6d 78 50 68 61 6e 74 6f 6d 52 65 int mxPhantomRe
5190: 71 20 3d 20 32 30 30 3b 20 2f 2a 20 4d 61 78 20 q = 200; /* Max
51a0: 6e 75 6d 62 65 72 20 6f 66 20 70 68 61 6e 74 6f number of phanto
51b0: 6d 73 20 74 6f 20 72 65 71 75 65 73 74 20 70 65 ms to request pe
51c0: 72 20 63 6f 6d 6d 20 2a 2f 0a 20 20 63 6f 6e 73 r comm */. cons
51d0: 74 20 63 68 61 72 20 2a 7a 43 6f 6f 6b 69 65 3b t char *zCookie;
51e0: 20 20 20 20 2f 2a 20 53 65 72 76 65 72 20 63 6f /* Server co
51f0: 6f 6b 69 65 20 2a 2f 0a 20 20 42 6c 6f 62 20 73 okie */. Blob s
5200: 65 6e 64 3b 20 20 20 20 20 20 20 20 2f 2a 20 54 end; /* T
5210: 65 78 74 20 77 65 20 61 72 65 20 73 65 6e 64 69 ext we are sendi
5220: 6e 67 20 74 6f 20 74 68 65 20 73 65 72 76 65 72 ng to the server
5230: 20 2a 2f 0a 20 20 42 6c 6f 62 20 72 65 63 76 3b */. Blob recv;
5240: 20 20 20 20 20 20 20 20 2f 2a 20 52 65 70 6c 79 /* Reply
5250: 20 77 65 20 67 6f 74 20 62 61 63 6b 20 66 72 6f we got back fro
5260: 6d 20 74 68 65 20 73 65 72 76 65 72 20 2a 2f 0a m the server */.
5270: 20 20 58 66 65 72 20 78 66 65 72 3b 20 20 20 20 Xfer xfer;
5280: 20 20 20 20 2f 2a 20 54 72 61 6e 73 66 65 72 20 /* Transfer
5290: 64 61 74 61 20 2a 2f 0a 0a 20 20 6d 65 6d 73 65 data */.. memse
52a0: 74 28 26 78 66 65 72 2c 20 30 2c 20 73 69 7a 65 t(&xfer, 0, size
52b0: 6f 66 28 78 66 65 72 29 29 3b 0a 20 20 78 66 65 of(xfer));. xfe
52c0: 72 2e 70 49 6e 20 3d 20 26 72 65 63 76 3b 0a 20 r.pIn = &recv;.
52d0: 20 78 66 65 72 2e 70 4f 75 74 20 3d 20 26 73 65 xfer.pOut = &se
52e0: 6e 64 3b 0a 20 20 78 66 65 72 2e 6d 78 53 65 6e nd;. xfer.mxSen
52f0: 64 20 3d 20 64 62 5f 67 65 74 5f 69 6e 74 28 22 d = db_get_int("
5300: 6d 61 78 2d 75 70 6c 6f 61 64 22 2c 20 32 35 30 max-upload", 250
5310: 30 30 30 29 3b 0a 0a 20 20 61 73 73 65 72 74 28 000);.. assert(
5320: 20 70 75 73 68 46 6c 61 67 20 7c 7c 20 70 75 6c pushFlag || pul
5330: 6c 46 6c 61 67 20 7c 7c 20 63 6c 6f 6e 65 46 6c lFlag || cloneFl
5340: 61 67 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 ag );. assert(
5350: 21 67 2e 75 72 6c 49 73 46 69 6c 65 20 29 3b 20 !g.urlIsFile );
5360: 20 20 20 20 20 20 20 20 20 2f 2a 20 54 68 69 73 /* This
5370: 20 6f 6e 6c 79 20 77 6f 72 6b 73 20 66 6f 72 20 only works for
5380: 6e 65 74 77 6f 72 6b 69 6e 67 20 2a 2f 0a 0a 20 networking */..
5390: 20 64 62 5f 62 65 67 69 6e 5f 74 72 61 6e 73 61 db_begin_transa
53a0: 63 74 69 6f 6e 28 29 3b 0a 20 20 64 62 5f 6d 75 ction();. db_mu
53b0: 6c 74 69 5f 65 78 65 63 28 0a 20 20 20 20 22 43 lti_exec(. "C
53c0: 52 45 41 54 45 20 54 45 4d 50 20 54 41 42 4c 45 REATE TEMP TABLE
53d0: 20 6f 6e 72 65 6d 6f 74 65 28 72 69 64 20 49 4e onremote(rid IN
53e0: 54 45 47 45 52 20 50 52 49 4d 41 52 59 20 4b 45 TEGER PRIMARY KE
53f0: 59 29 3b 22 0a 20 20 29 3b 0a 20 20 62 6c 6f 62 Y);". );. blob
5400: 61 72 72 61 79 5f 7a 65 72 6f 28 78 66 65 72 2e array_zero(xfer.
5410: 61 54 6f 6b 65 6e 2c 20 63 6f 75 6e 74 28 78 66 aToken, count(xf
5420: 65 72 2e 61 54 6f 6b 65 6e 29 29 3b 0a 20 20 62 er.aToken));. b
5430: 6c 6f 62 5f 7a 65 72 6f 28 26 73 65 6e 64 29 3b lob_zero(&send);
5440: 0a 20 20 62 6c 6f 62 5f 7a 65 72 6f 28 26 72 65 . blob_zero(&re
5450: 63 76 29 3b 0a 20 20 62 6c 6f 62 5f 7a 65 72 6f cv);. blob_zero
5460: 28 26 78 66 65 72 2e 65 72 72 29 3b 0a 20 20 62 (&xfer.err);. b
5470: 6c 6f 62 5f 7a 65 72 6f 28 26 78 66 65 72 2e 6c lob_zero(&xfer.l
5480: 69 6e 65 29 3b 0a 0a 20 20 2f 2a 0a 20 20 2a 2a ine);.. /*. **
5490: 20 41 6c 77 61 79 73 20 62 65 67 69 6e 20 77 69 Always begin wi
54a0: 74 68 20 61 20 63 6c 6f 6e 65 2c 20 70 75 6c 6c th a clone, pull
54b0: 2c 20 6f 72 20 70 75 73 68 20 6d 65 73 73 61 67 , or push messag
54c0: 65 0a 20 20 2a 2f 0a 20 20 69 66 28 20 63 6c 6f e. */. if( clo
54d0: 6e 65 46 6c 61 67 20 29 7b 0a 20 20 20 20 62 6c neFlag ){. bl
54e0: 6f 62 5f 61 70 70 65 6e 64 66 28 26 73 65 6e 64 ob_appendf(&send
54f0: 2c 20 22 63 6c 6f 6e 65 5c 6e 22 29 3b 0a 20 20 , "clone\n");.
5500: 20 20 70 75 73 68 46 6c 61 67 20 3d 20 30 3b 0a pushFlag = 0;.
5510: 20 20 20 20 70 75 6c 6c 46 6c 61 67 20 3d 20 30 pullFlag = 0
5520: 3b 0a 20 20 20 20 6e 4d 73 67 2b 2b 3b 0a 20 20 ;. nMsg++;.
5530: 7d 65 6c 73 65 20 69 66 28 20 70 75 6c 6c 46 6c }else if( pullFl
5540: 61 67 20 29 7b 0a 20 20 20 20 62 6c 6f 62 5f 61 ag ){. blob_a
5550: 70 70 65 6e 64 66 28 26 73 65 6e 64 2c 20 22 70 ppendf(&send, "p
5560: 75 6c 6c 20 25 73 20 25 73 5c 6e 22 2c 20 7a 53 ull %s %s\n", zS
5570: 43 6f 64 65 2c 20 7a 50 43 6f 64 65 29 3b 0a 20 Code, zPCode);.
5580: 20 20 20 6e 4d 73 67 2b 2b 3b 0a 20 20 7d 0a 20 nMsg++;. }.
5590: 20 69 66 28 20 70 75 73 68 46 6c 61 67 20 29 7b if( pushFlag ){
55a0: 0a 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 . blob_append
55b0: 66 28 26 73 65 6e 64 2c 20 22 70 75 73 68 20 25 f(&send, "push %
55c0: 73 20 25 73 5c 6e 22 2c 20 7a 53 43 6f 64 65 2c s %s\n", zSCode,
55d0: 20 7a 50 43 6f 64 65 29 3b 0a 20 20 20 20 6e 4d zPCode);. nM
55e0: 73 67 2b 2b 3b 0a 20 20 7d 0a 0a 0a 20 20 77 68 sg++;. }... wh
55f0: 69 6c 65 28 20 67 6f 20 29 7b 0a 20 20 20 20 69 ile( go ){. i
5600: 6e 74 20 6e 65 77 50 68 61 6e 74 6f 6d 20 3d 20 nt newPhantom =
5610: 30 3b 0a 0a 20 20 20 20 2f 2a 20 53 65 6e 64 20 0;.. /* Send
5620: 6d 61 6b 65 20 74 68 65 20 6d 6f 73 74 20 72 65 make the most re
5630: 63 65 6e 74 6c 79 20 72 65 63 65 69 76 65 64 20 cently received
5640: 63 6f 6f 6b 69 65 2e 20 20 4c 65 74 20 74 68 65 cookie. Let the
5650: 20 73 65 72 76 65 72 0a 20 20 20 20 2a 2a 20 66 server. ** f
5660: 69 67 75 72 65 20 6f 75 74 20 69 66 20 74 68 69 igure out if thi
5670: 73 20 69 73 20 61 20 63 6f 6f 6b 69 65 20 74 68 s is a cookie th
5680: 61 74 20 69 74 20 63 61 72 65 73 20 61 62 6f 75 at it cares abou
5690: 74 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 7a 43 t.. */. zC
56a0: 6f 6f 6b 69 65 20 3d 20 64 62 5f 67 65 74 28 22 ookie = db_get("
56b0: 63 6f 6f 6b 69 65 22 2c 20 30 29 3b 0a 20 20 20 cookie", 0);.
56c0: 20 69 66 28 20 7a 43 6f 6f 6b 69 65 20 29 7b 0a if( zCookie ){.
56d0: 20 20 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e blob_appen
56e0: 64 66 28 26 73 65 6e 64 2c 20 22 63 6f 6f 6b 69 df(&send, "cooki
56f0: 65 20 25 73 5c 6e 22 2c 20 7a 43 6f 6f 6b 69 65 e %s\n", zCookie
5700: 29 3b 0a 20 20 20 20 7d 0a 20 20 20 20 0a 20 20 );. }. .
5710: 20 20 2f 2a 20 47 65 6e 65 72 61 74 65 20 67 69 /* Generate gi
5720: 6d 6d 65 20 6d 65 73 73 61 67 65 73 20 66 6f 72 mme messages for
5730: 20 70 68 61 6e 74 6f 6d 73 20 61 6e 64 20 6c 65 phantoms and le
5740: 61 66 20 6d 65 73 73 61 67 65 73 0a 20 20 20 20 af messages.
5750: 2a 2a 20 66 6f 72 20 61 6c 6c 20 6c 65 61 76 65 ** for all leave
5760: 73 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 69 66 s.. */. if
5770: 28 20 70 75 6c 6c 46 6c 61 67 20 7c 7c 20 63 6c ( pullFlag || cl
5780: 6f 6e 65 46 6c 61 67 20 29 7b 0a 20 20 20 20 20 oneFlag ){.
5790: 20 72 65 71 75 65 73 74 5f 70 68 61 6e 74 6f 6d request_phantom
57a0: 73 28 26 78 66 65 72 2c 20 6d 78 50 68 61 6e 74 s(&xfer, mxPhant
57b0: 6f 6d 52 65 71 29 3b 0a 20 20 20 20 7d 0a 20 20 omReq);. }.
57c0: 20 20 69 66 28 20 70 75 73 68 46 6c 61 67 20 29 if( pushFlag )
57d0: 7b 0a 20 20 20 20 20 20 73 65 6e 64 5f 75 6e 73 {. send_uns
57e0: 65 6e 74 28 26 78 66 65 72 29 3b 0a 20 20 20 20 ent(&xfer);.
57f0: 20 20 6e 4d 73 67 20 2b 3d 20 73 65 6e 64 5f 75 nMsg += send_u
5800: 6e 63 6c 75 73 74 65 72 65 64 28 26 78 66 65 72 nclustered(&xfer
5810: 29 3b 0a 20 20 20 20 7d 0a 0a 20 20 20 20 2f 2a );. }.. /*
5820: 20 45 78 63 68 61 6e 67 65 20 6d 65 73 73 61 67 Exchange messag
5830: 65 73 20 77 69 74 68 20 74 68 65 20 73 65 72 76 es with the serv
5840: 65 72 20 2a 2f 0a 20 20 20 20 6e 46 69 6c 65 53 er */. nFileS
5850: 65 6e 64 20 3d 20 78 66 65 72 2e 6e 46 69 6c 65 end = xfer.nFile
5860: 53 65 6e 74 20 2b 20 78 66 65 72 2e 6e 44 65 6c Sent + xfer.nDel
5870: 74 61 53 65 6e 74 3b 0a 20 20 20 20 70 72 69 6e taSent;. prin
5880: 74 66 28 22 53 65 6e 74 3a 20 20 20 20 20 20 25 tf("Sent: %
5890: 31 30 64 20 62 79 74 65 73 2c 20 25 35 64 20 6d 10d bytes, %5d m
58a0: 65 73 73 61 67 65 73 2c 20 25 35 64 20 66 69 6c essages, %5d fil
58b0: 65 73 20 28 25 64 2b 25 64 29 5c 6e 22 2c 0a 20 es (%d+%d)\n",.
58c0: 20 20 20 20 20 20 20 20 20 20 20 62 6c 6f 62 5f blob_
58d0: 73 69 7a 65 28 26 73 65 6e 64 29 2c 20 6e 4d 73 size(&send), nMs
58e0: 67 2b 78 66 65 72 2e 6e 47 69 6d 6d 65 53 65 6e g+xfer.nGimmeSen
58f0: 74 2b 78 66 65 72 2e 6e 49 47 6f 74 53 65 6e 74 t+xfer.nIGotSent
5900: 2c 0a 20 20 20 20 20 20 20 20 20 20 20 20 6e 46 ,. nF
5910: 69 6c 65 53 65 6e 64 2c 20 78 66 65 72 2e 6e 46 ileSend, xfer.nF
5920: 69 6c 65 53 65 6e 74 2c 20 78 66 65 72 2e 6e 44 ileSent, xfer.nD
5930: 65 6c 74 61 53 65 6e 74 29 3b 0a 20 20 20 20 6e eltaSent);. n
5940: 4d 73 67 20 3d 20 30 3b 0a 20 20 20 20 78 66 65 Msg = 0;. xfe
5950: 72 2e 6e 46 69 6c 65 53 65 6e 74 20 3d 20 30 3b r.nFileSent = 0;
5960: 0a 20 20 20 20 78 66 65 72 2e 6e 44 65 6c 74 61 . xfer.nDelta
5970: 53 65 6e 74 20 3d 20 30 3b 0a 20 20 20 20 78 66 Sent = 0;. xf
5980: 65 72 2e 6e 47 69 6d 6d 65 53 65 6e 74 20 3d 20 er.nGimmeSent =
5990: 30 3b 0a 20 20 20 20 66 66 6c 75 73 68 28 73 74 0;. fflush(st
59a0: 64 6f 75 74 29 3b 0a 20 20 20 20 68 74 74 70 5f dout);. http_
59b0: 65 78 63 68 61 6e 67 65 28 26 73 65 6e 64 2c 20 exchange(&send,
59c0: 26 72 65 63 76 29 3b 0a 20 20 20 20 62 6c 6f 62 &recv);. blob
59d0: 5f 72 65 73 65 74 28 26 73 65 6e 64 29 3b 0a 0a _reset(&send);..
59e0: 20 20 20 20 2f 2a 20 42 65 67 69 6e 20 63 6f 6e /* Begin con
59f0: 73 74 72 75 63 74 69 6e 67 20 74 68 65 20 6e 65 structing the ne
5a00: 78 74 20 6d 65 73 73 61 67 65 20 28 77 68 69 63 xt message (whic
5a10: 68 20 6d 69 67 68 74 20 6e 65 76 65 72 20 62 65 h might never be
5a20: 0a 20 20 20 20 2a 2a 20 73 65 6e 74 29 20 62 79 . ** sent) by
5a30: 20 62 65 67 69 6e 6e 69 6e 67 20 77 69 74 68 20 beginning with
5a40: 74 68 65 20 70 75 6c 6c 20 6f 72 20 70 75 73 68 the pull or push
5a50: 20 6d 65 73 73 61 67 65 73 0a 20 20 20 20 2a 2f messages. */
5a60: 0a 20 20 20 20 69 66 28 20 70 75 6c 6c 46 6c 61 . if( pullFla
5a70: 67 20 29 7b 0a 20 20 20 20 20 20 62 6c 6f 62 5f g ){. blob_
5a80: 61 70 70 65 6e 64 66 28 26 73 65 6e 64 2c 20 22 appendf(&send, "
5a90: 70 75 6c 6c 20 25 73 20 25 73 5c 6e 22 2c 20 7a pull %s %s\n", z
5aa0: 53 43 6f 64 65 2c 20 7a 50 43 6f 64 65 29 3b 0a SCode, zPCode);.
5ab0: 20 20 20 20 20 20 6e 4d 73 67 2b 2b 3b 0a 20 20 nMsg++;.
5ac0: 20 20 7d 0a 20 20 20 20 69 66 28 20 70 75 73 68 }. if( push
5ad0: 46 6c 61 67 20 29 7b 0a 20 20 20 20 20 20 62 6c Flag ){. bl
5ae0: 6f 62 5f 61 70 70 65 6e 64 66 28 26 73 65 6e 64 ob_appendf(&send
5af0: 2c 20 22 70 75 73 68 20 25 73 20 25 73 5c 6e 22 , "push %s %s\n"
5b00: 2c 20 7a 53 43 6f 64 65 2c 20 7a 50 43 6f 64 65 , zSCode, zPCode
5b10: 29 3b 0a 20 20 20 20 20 20 6e 4d 73 67 2b 2b 3b );. nMsg++;
5b20: 0a 20 20 20 20 7d 0a 0a 20 20 20 20 2f 2a 20 50 . }.. /* P
5b30: 72 6f 63 65 73 73 20 74 68 65 20 72 65 70 6c 79 rocess the reply
5b40: 20 74 68 61 74 20 63 61 6d 65 20 62 61 63 6b 20 that came back
5b50: 66 72 6f 6d 20 74 68 65 20 73 65 72 76 65 72 20 from the server
5b60: 2a 2f 0a 20 20 20 20 77 68 69 6c 65 28 20 62 6c */. while( bl
5b70: 6f 62 5f 6c 69 6e 65 28 26 72 65 63 76 2c 20 26 ob_line(&recv, &
5b80: 78 66 65 72 2e 6c 69 6e 65 29 20 29 7b 0a 20 20 xfer.line) ){.
5b90: 20 20 20 20 69 66 28 20 62 6c 6f 62 5f 62 75 66 if( blob_buf
5ba0: 66 65 72 28 26 78 66 65 72 2e 6c 69 6e 65 29 5b fer(&xfer.line)[
5bb0: 30 5d 3d 3d 27 23 27 20 29 7b 0a 20 20 20 20 20 0]=='#' ){.
5bc0: 20 20 20 63 6f 6e 74 69 6e 75 65 3b 0a 20 20 20 continue;.
5bd0: 20 20 20 7d 0a 20 20 20 20 20 20 78 66 65 72 2e }. xfer.
5be0: 6e 54 6f 6b 65 6e 20 3d 20 62 6c 6f 62 5f 74 6f nToken = blob_to
5bf0: 6b 65 6e 69 7a 65 28 26 78 66 65 72 2e 6c 69 6e kenize(&xfer.lin
5c00: 65 2c 20 78 66 65 72 2e 61 54 6f 6b 65 6e 2c 20 e, xfer.aToken,
5c10: 63 6f 75 6e 74 28 78 66 65 72 2e 61 54 6f 6b 65 count(xfer.aToke
5c20: 6e 29 29 3b 0a 20 20 20 20 20 20 6e 4d 73 67 2b n));. nMsg+
5c30: 2b 3b 0a 20 20 20 20 20 20 70 72 69 6e 74 66 28 +;. printf(
5c40: 22 5c 72 25 64 22 2c 20 6e 4d 73 67 29 3b 0a 20 "\r%d", nMsg);.
5c50: 20 20 20 20 20 66 66 6c 75 73 68 28 73 74 64 6f fflush(stdo
5c60: 75 74 29 3b 0a 0a 20 20 20 20 20 20 2f 2a 20 20 ut);.. /*
5c70: 20 66 69 6c 65 20 55 55 49 44 20 53 49 5a 45 20 file UUID SIZE
5c80: 5c 6e 20 43 4f 4e 54 45 4e 54 0a 20 20 20 20 20 \n CONTENT.
5c90: 20 2a 2a 20 20 20 66 69 6c 65 20 55 55 49 44 20 ** file UUID
5ca0: 44 45 4c 54 41 53 52 43 20 53 49 5a 45 20 5c 6e DELTASRC SIZE \n
5cb0: 20 43 4f 4e 54 45 4e 54 0a 20 20 20 20 20 20 2a CONTENT. *
5cc0: 2a 0a 20 20 20 20 20 20 2a 2a 20 52 65 63 65 69 *. ** Recei
5cd0: 76 65 20 61 20 66 69 6c 65 20 74 72 61 6e 73 6d ve a file transm
5ce0: 69 74 74 65 64 20 66 72 6f 6d 20 74 68 65 20 73 itted from the s
5cf0: 65 72 76 65 72 2e 0a 20 20 20 20 20 20 2a 2f 0a erver.. */.
5d00: 20 20 20 20 20 20 69 66 28 20 62 6c 6f 62 5f 65 if( blob_e
5d10: 71 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 q(&xfer.aToken[0
5d20: 5d 2c 22 66 69 6c 65 22 29 20 29 7b 0a 20 20 20 ],"file") ){.
5d30: 20 20 20 20 20 78 66 65 72 5f 61 63 63 65 70 74 xfer_accept
5d40: 5f 66 69 6c 65 28 26 78 66 65 72 29 3b 0a 20 20 _file(&xfer);.
5d50: 20 20 20 20 7d 65 6c 73 65 0a 0a 20 20 20 20 20 }else..
5d60: 20 2f 2a 20 20 20 67 69 6d 6d 65 20 55 55 49 44 /* gimme UUID
5d70: 0a 20 20 20 20 20 20 2a 2a 0a 20 20 20 20 20 20 . **.
5d80: 2a 2a 20 53 65 72 76 65 72 20 69 73 20 72 65 71 ** Server is req
5d90: 75 65 73 74 69 6e 67 20 61 20 66 69 6c 65 2e 20 uesting a file.
5da0: 20 49 66 20 74 68 65 20 66 69 6c 65 20 69 73 20 If the file is
5db0: 61 20 6d 61 6e 69 66 65 73 74 2c 20 61 73 73 75 a manifest, assu
5dc0: 6d 65 0a 20 20 20 20 20 20 2a 2a 20 74 68 61 74 me. ** that
5dd0: 20 74 68 65 20 73 65 72 76 65 72 20 77 69 6c 6c the server will
5de0: 20 61 6c 73 6f 20 77 61 6e 74 20 74 6f 20 6b 6e also want to kn
5df0: 6f 77 20 61 6c 6c 20 6f 66 20 74 68 65 20 63 6f ow all of the co
5e00: 6e 74 65 6e 74 20 66 69 6c 65 73 0a 20 20 20 20 ntent files.
5e10: 20 20 2a 2a 20 61 73 73 6f 63 69 61 74 65 64 20 ** associated
5e20: 77 69 74 68 20 74 68 65 20 6d 61 6e 69 66 65 73 with the manifes
5e30: 74 20 61 6e 64 20 73 65 6e 64 20 74 68 6f 73 65 t and send those
5e40: 20 74 6f 6f 2e 0a 20 20 20 20 20 20 2a 2f 0a 20 too.. */.
5e50: 20 20 20 20 20 69 66 28 20 62 6c 6f 62 5f 65 71 if( blob_eq
5e60: 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d (&xfer.aToken[0]
5e70: 2c 20 22 67 69 6d 6d 65 22 29 0a 20 20 20 20 20 , "gimme").
5e80: 20 20 26 26 20 78 66 65 72 2e 6e 54 6f 6b 65 6e && xfer.nToken
5e90: 3d 3d 32 0a 20 20 20 20 20 20 20 26 26 20 62 6c ==2. && bl
5ea0: 6f 62 5f 69 73 5f 75 75 69 64 28 26 78 66 65 72 ob_is_uuid(&xfer
5eb0: 2e 61 54 6f 6b 65 6e 5b 31 5d 29 0a 20 20 20 20 .aToken[1]).
5ec0: 20 20 29 7b 0a 20 20 20 20 20 20 20 20 69 66 28 ){. if(
5ed0: 20 70 75 73 68 46 6c 61 67 20 29 7b 0a 20 20 20 pushFlag ){.
5ee0: 20 20 20 20 20 20 20 69 6e 74 20 72 69 64 20 3d int rid =
5ef0: 20 72 69 64 5f 66 72 6f 6d 5f 75 75 69 64 28 26 rid_from_uuid(&
5f00: 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 2c 20 xfer.aToken[1],
5f10: 30 29 3b 0a 20 20 20 20 20 20 20 20 20 20 73 65 0);. se
5f20: 6e 64 5f 66 69 6c 65 28 26 78 66 65 72 2c 20 72 nd_file(&xfer, r
5f30: 69 64 2c 20 26 78 66 65 72 2e 61 54 6f 6b 65 6e id, &xfer.aToken
5f40: 5b 31 5d 2c 20 30 29 3b 0a 20 20 20 20 20 20 20 [1], 0);.
5f50: 20 7d 0a 20 20 20 20 20 20 7d 65 6c 73 65 0a 20 }. }else.
5f60: 20 0a 20 20 20 20 20 20 2f 2a 20 20 20 69 67 6f . /* igo
5f70: 74 20 55 55 49 44 0a 20 20 20 20 20 20 2a 2a 0a t UUID. **.
5f80: 20 20 20 20 20 20 2a 2a 20 53 65 72 76 65 72 20 ** Server
5f90: 61 6e 6e 6f 75 6e 63 65 73 20 74 68 61 74 20 69 announces that i
5fa0: 74 20 68 61 73 20 61 20 70 61 72 74 69 63 75 6c t has a particul
5fb0: 61 72 20 66 69 6c 65 2e 20 20 49 66 20 74 68 69 ar file. If thi
5fc0: 73 20 69 73 0a 20 20 20 20 20 20 2a 2a 20 6e 6f s is. ** no
5fd0: 74 20 61 20 66 69 6c 65 20 74 68 61 74 20 77 65 t a file that we
5fe0: 20 68 61 76 65 20 61 6e 64 20 77 65 20 61 72 65 have and we are
5ff0: 20 70 75 6c 6c 69 6e 67 2c 20 74 68 65 6e 20 63 pulling, then c
6000: 72 65 61 74 65 20 61 0a 20 20 20 20 20 20 2a 2a reate a. **
6010: 20 70 68 61 6e 74 6f 6d 20 74 6f 20 63 61 75 73 phantom to caus
6020: 65 20 74 68 69 73 20 66 69 6c 65 20 74 6f 20 62 e this file to b
6030: 65 20 72 65 71 75 65 73 74 65 64 20 6f 6e 20 74 e requested on t
6040: 68 65 20 6e 65 78 74 20 63 79 63 6c 65 2e 0a 20 he next cycle..
6050: 20 20 20 20 20 2a 2a 20 41 6c 77 61 79 73 20 72 ** Always r
6060: 65 6d 65 6d 62 65 72 20 74 68 61 74 20 74 68 65 emember that the
6070: 20 73 65 72 76 65 72 20 68 61 73 20 74 68 69 73 server has this
6080: 20 66 69 6c 65 20 73 6f 20 74 68 61 74 20 77 65 file so that we
6090: 20 64 6f 0a 20 20 20 20 20 20 2a 2a 20 6e 6f 74 do. ** not
60a0: 20 74 72 61 6e 73 6d 69 74 20 69 74 20 62 79 20 transmit it by
60b0: 61 63 63 69 64 65 6e 74 2e 0a 20 20 20 20 20 20 accident..
60c0: 2a 2f 0a 20 20 20 20 20 20 69 66 28 20 78 66 65 */. if( xfe
60d0: 72 2e 6e 54 6f 6b 65 6e 3d 3d 32 0a 20 20 20 20 r.nToken==2.
60e0: 20 20 20 26 26 20 62 6c 6f 62 5f 65 71 28 26 78 && blob_eq(&x
60f0: 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d 2c 20 22 fer.aToken[0], "
6100: 69 67 6f 74 22 29 0a 20 20 20 20 20 20 20 26 26 igot"). &&
6110: 20 62 6c 6f 62 5f 69 73 5f 75 75 69 64 28 26 78 blob_is_uuid(&x
6120: 66 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 29 0a 20 fer.aToken[1]).
6130: 20 20 20 20 20 29 7b 0a 20 20 20 20 20 20 20 20 ){.
6140: 69 6e 74 20 72 69 64 20 3d 20 30 3b 0a 20 20 20 int rid = 0;.
6150: 20 20 20 20 20 69 66 28 20 70 75 6c 6c 46 6c 61 if( pullFla
6160: 67 20 7c 7c 20 63 6c 6f 6e 65 46 6c 61 67 20 29 g || cloneFlag )
6170: 7b 0a 20 20 20 20 20 20 20 20 20 20 69 66 28 20 {. if(
6180: 21 64 62 5f 65 78 69 73 74 73 28 22 53 45 4c 45 !db_exists("SELE
6190: 43 54 20 31 20 46 52 4f 4d 20 62 6c 6f 62 20 57 CT 1 FROM blob W
61a0: 48 45 52 45 20 75 75 69 64 3d 27 25 62 27 20 41 HERE uuid='%b' A
61b0: 4e 44 20 73 69 7a 65 3e 3d 30 22 2c 0a 20 20 20 ND size>=0",.
61c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 26 78 66 &xf
61d0: 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 29 20 29 7b er.aToken[1]) ){
61e0: 0a 20 20 20 20 20 20 20 20 20 20 20 20 72 69 64 . rid
61f0: 20 3d 20 63 6f 6e 74 65 6e 74 5f 70 75 74 28 30 = content_put(0
6200: 2c 20 62 6c 6f 62 5f 73 74 72 28 26 78 66 65 72 , blob_str(&xfer
6210: 2e 61 54 6f 6b 65 6e 5b 31 5d 29 2c 20 30 29 3b .aToken[1]), 0);
6220: 0a 20 20 20 20 20 20 20 20 20 20 20 20 6e 65 77 . new
6230: 50 68 61 6e 74 6f 6d 20 3d 20 31 3b 0a 20 20 20 Phantom = 1;.
6240: 20 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 20 }.
6250: 20 7d 0a 20 20 20 20 20 20 20 20 69 66 28 20 72 }. if( r
6260: 69 64 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 20 id==0 ){.
6270: 20 20 20 72 69 64 20 3d 20 72 69 64 5f 66 72 6f rid = rid_fro
6280: 6d 5f 75 75 69 64 28 26 78 66 65 72 2e 61 54 6f m_uuid(&xfer.aTo
6290: 6b 65 6e 5b 31 5d 2c 20 30 29 3b 0a 20 20 20 20 ken[1], 0);.
62a0: 20 20 20 20 7d 0a 20 20 20 20 20 20 20 20 72 65 }. re
62b0: 6d 6f 74 65 5f 68 61 73 28 72 69 64 29 3b 0a 20 mote_has(rid);.
62c0: 20 20 20 20 20 7d 65 6c 73 65 0a 20 20 20 20 0a }else. .
62d0: 20 20 20 20 20 20 0a 20 20 20 20 20 20 2f 2a 20 . /*
62e0: 20 20 70 75 73 68 20 20 53 45 52 56 45 52 43 4f push SERVERCO
62f0: 44 45 20 20 50 52 4f 44 55 43 54 43 4f 44 45 0a DE PRODUCTCODE.
6300: 20 20 20 20 20 20 2a 2a 0a 20 20 20 20 20 20 2a **. *
6310: 2a 20 53 68 6f 75 6c 64 20 6f 6e 6c 79 20 68 61 * Should only ha
6320: 70 70 65 6e 20 69 6e 20 72 65 73 70 6f 6e 73 65 ppen in response
6330: 20 74 6f 20 61 20 63 6c 6f 6e 65 2e 20 20 54 68 to a clone. Th
6340: 69 73 20 6d 65 73 73 61 67 65 20 74 65 6c 6c 73 is message tells
6350: 0a 20 20 20 20 20 20 2a 2a 20 74 68 65 20 63 6c . ** the cl
6360: 69 65 6e 74 20 77 68 61 74 20 70 72 6f 64 75 63 ient what produc
6370: 74 20 74 6f 20 75 73 65 20 66 6f 72 20 74 68 65 t to use for the
6380: 20 6e 65 77 20 64 61 74 61 62 61 73 65 2e 0a 20 new database..
6390: 20 20 20 20 20 2a 2f 0a 20 20 20 20 20 20 69 66 */. if
63a0: 28 20 62 6c 6f 62 5f 65 71 28 26 78 66 65 72 2e ( blob_eq(&xfer.
63b0: 61 54 6f 6b 65 6e 5b 30 5d 2c 22 70 75 73 68 22 aToken[0],"push"
63c0: 29 0a 20 20 20 20 20 20 20 26 26 20 78 66 65 72 ). && xfer
63d0: 2e 6e 54 6f 6b 65 6e 3d 3d 33 0a 20 20 20 20 20 .nToken==3.
63e0: 20 20 26 26 20 63 6c 6f 6e 65 46 6c 61 67 0a 20 && cloneFlag.
63f0: 20 20 20 20 20 20 26 26 20 62 6c 6f 62 5f 69 73 && blob_is
6400: 5f 75 75 69 64 28 26 78 66 65 72 2e 61 54 6f 6b _uuid(&xfer.aTok
6410: 65 6e 5b 31 5d 29 0a 20 20 20 20 20 20 20 26 26 en[1]). &&
6420: 20 62 6c 6f 62 5f 69 73 5f 75 75 69 64 28 26 78 blob_is_uuid(&x
6430: 66 65 72 2e 61 54 6f 6b 65 6e 5b 32 5d 29 0a 20 fer.aToken[2]).
6440: 20 20 20 20 20 29 7b 0a 20 20 20 20 20 20 20 20 ){.
6450: 69 66 28 20 62 6c 6f 62 5f 65 71 5f 73 74 72 28 if( blob_eq_str(
6460: 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 2c &xfer.aToken[1],
6470: 20 7a 53 43 6f 64 65 2c 20 2d 31 29 20 29 7b 0a zSCode, -1) ){.
6480: 20 20 20 20 20 20 20 20 20 20 66 6f 73 73 69 6c fossil
6490: 5f 66 61 74 61 6c 28 22 73 65 72 76 65 72 20 6c _fatal("server l
64a0: 6f 6f 70 22 29 3b 0a 20 20 20 20 20 20 20 20 7d oop");. }
64b0: 0a 20 20 20 20 20 20 20 20 69 66 28 20 7a 50 43 . if( zPC
64c0: 6f 64 65 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 ode==0 ){.
64d0: 20 20 20 20 7a 50 43 6f 64 65 20 3d 20 6d 70 72 zPCode = mpr
64e0: 69 6e 74 66 28 22 25 62 22 2c 20 26 78 66 65 72 intf("%b", &xfer
64f0: 2e 61 54 6f 6b 65 6e 5b 32 5d 29 3b 0a 20 20 20 .aToken[2]);.
6500: 20 20 20 20 20 20 20 64 62 5f 73 65 74 28 22 70 db_set("p
6510: 72 6f 6a 65 63 74 2d 63 6f 64 65 22 2c 20 7a 50 roject-code", zP
6520: 43 6f 64 65 2c 20 30 29 3b 0a 20 20 20 20 20 20 Code, 0);.
6530: 20 20 7d 0a 20 20 20 20 20 20 20 20 62 6c 6f 62 }. blob
6540: 5f 61 70 70 65 6e 64 66 28 26 73 65 6e 64 2c 20 _appendf(&send,
6550: 22 63 6c 6f 6e 65 5c 6e 22 29 3b 0a 20 20 20 20 "clone\n");.
6560: 20 20 20 20 6e 4d 73 67 2b 2b 3b 0a 20 20 20 20 nMsg++;.
6570: 20 20 7d 65 6c 73 65 0a 20 20 20 20 20 20 0a 20 }else. .
6580: 20 20 20 20 20 2f 2a 20 20 20 20 63 6f 6f 6b 69 /* cooki
6590: 65 20 54 45 58 54 0a 20 20 20 20 20 20 2a 2a 0a e TEXT. **.
65a0: 20 20 20 20 20 20 2a 2a 20 54 68 65 20 73 65 72 ** The ser
65b0: 76 65 72 20 6d 69 67 68 74 20 69 6e 63 6c 75 64 ver might includ
65c0: 65 20 61 20 63 6f 6f 6b 69 65 20 69 6e 20 69 74 e a cookie in it
65d0: 73 20 72 65 70 6c 79 2e 20 20 54 68 65 20 63 6c s reply. The cl
65e0: 69 65 6e 74 0a 20 20 20 20 20 20 2a 2a 20 73 68 ient. ** sh
65f0: 6f 75 6c 64 20 72 65 6d 65 6d 62 65 72 20 74 68 ould remember th
6600: 69 73 20 63 6f 6f 6b 69 65 20 61 6e 64 20 73 65 is cookie and se
6610: 6e 64 20 69 74 20 62 61 63 6b 20 74 6f 20 74 68 nd it back to th
6620: 65 20 73 65 72 76 65 72 0a 20 20 20 20 20 20 2a e server. *
6630: 2a 20 69 6e 20 69 74 73 20 6e 65 78 74 20 71 75 * in its next qu
6640: 65 72 79 2e 0a 20 20 20 20 20 20 2a 2a 0a 20 20 ery.. **.
6650: 20 20 20 20 2a 2a 20 45 61 63 68 20 63 6f 6f 6b ** Each cook
6660: 69 65 20 72 65 63 65 69 76 65 64 20 6f 76 65 72 ie received over
6670: 77 72 69 74 65 73 20 74 68 65 20 70 72 69 6f 72 writes the prior
6680: 20 63 6f 6f 6b 69 65 20 66 72 6f 6d 20 74 68 65 cookie from the
6690: 0a 20 20 20 20 20 20 2a 2a 20 73 61 6d 65 20 73 . ** same s
66a0: 65 72 76 65 72 2e 0a 20 20 20 20 20 20 2a 2f 0a erver.. */.
66b0: 20 20 20 20 20 20 69 66 28 20 62 6c 6f 62 5f 65 if( blob_e
66c0: 71 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 q(&xfer.aToken[0
66d0: 5d 2c 20 22 63 6f 6f 6b 69 65 22 29 20 26 26 20 ], "cookie") &&
66e0: 78 66 65 72 2e 6e 54 6f 6b 65 6e 3d 3d 32 20 29 xfer.nToken==2 )
66f0: 7b 0a 20 20 20 20 20 20 20 20 64 62 5f 73 65 74 {. db_set
6700: 28 22 63 6f 6f 6b 69 65 22 2c 20 62 6c 6f 62 5f ("cookie", blob_
6710: 73 74 72 28 26 78 66 65 72 2e 61 54 6f 6b 65 6e str(&xfer.aToken
6720: 5b 31 5d 29 2c 20 30 29 3b 0a 20 20 20 20 20 20 [1]), 0);.
6730: 7d 65 6c 73 65 0a 0a 20 20 20 20 20 20 2f 2a 20 }else.. /*
6740: 20 20 6d 65 73 73 61 67 65 20 4d 45 53 53 41 47 message MESSAG
6750: 45 0a 20 20 20 20 20 20 2a 2a 0a 20 20 20 20 20 E. **.
6760: 20 2a 2a 20 50 72 69 6e 74 20 61 20 6d 65 73 73 ** Print a mess
6770: 61 67 65 2e 20 20 53 69 6d 69 6c 61 72 20 74 6f age. Similar to
6780: 20 22 65 72 72 6f 72 22 20 62 75 74 20 64 6f 65 "error" but doe
6790: 73 20 6e 6f 74 20 73 74 6f 70 20 70 72 6f 63 65 s not stop proce
67a0: 73 73 69 6e 67 0a 20 20 20 20 20 20 2a 2f 20 20 ssing. */
67b0: 20 20 20 20 20 20 0a 20 20 20 20 20 20 69 66 28 . if(
67c0: 20 62 6c 6f 62 5f 65 71 28 26 78 66 65 72 2e 61 blob_eq(&xfer.a
67d0: 54 6f 6b 65 6e 5b 30 5d 2c 22 6d 65 73 73 61 67 Token[0],"messag
67e0: 65 22 29 20 26 26 20 78 66 65 72 2e 6e 54 6f 6b e") && xfer.nTok
67f0: 65 6e 3d 3d 32 20 29 7b 0a 20 20 20 20 20 20 20 en==2 ){.
6800: 20 63 68 61 72 20 2a 7a 4d 73 67 20 3d 20 62 6c char *zMsg = bl
6810: 6f 62 5f 74 65 72 6d 69 6e 61 74 65 28 26 78 66 ob_terminate(&xf
6820: 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 29 3b 0a 20 er.aToken[1]);.
6830: 20 20 20 20 20 20 20 64 65 66 6f 73 73 69 6c 69 defossili
6840: 7a 65 28 7a 4d 73 67 29 3b 0a 20 20 20 20 20 20 ze(zMsg);.
6850: 20 20 70 72 69 6e 74 66 28 22 53 65 72 76 65 72 printf("Server
6860: 20 73 61 79 73 3a 20 25 73 5c 6e 22 2c 20 7a 4d says: %s\n", zM
6870: 73 67 29 3b 0a 20 20 20 20 20 20 7d 65 6c 73 65 sg);. }else
6880: 0a 0a 20 20 20 20 20 20 2f 2a 20 20 20 65 72 72 .. /* err
6890: 6f 72 20 4d 45 53 53 41 47 45 0a 20 20 20 20 20 or MESSAGE.
68a0: 20 2a 2a 0a 20 20 20 20 20 20 2a 2a 20 52 65 70 **. ** Rep
68b0: 6f 72 74 20 61 6e 20 65 72 72 6f 72 20 61 6e 64 ort an error and
68c0: 20 61 62 61 6e 64 6f 6e 20 74 68 65 20 73 79 6e abandon the syn
68d0: 63 20 73 65 73 73 69 6f 6e 0a 20 20 20 20 20 20 c session.
68e0: 2a 2f 20 20 20 20 20 20 20 20 0a 20 20 20 20 20 */ .
68f0: 20 69 66 28 20 62 6c 6f 62 5f 65 71 28 26 78 66 if( blob_eq(&xf
6900: 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d 2c 22 65 72 er.aToken[0],"er
6910: 72 6f 72 22 29 20 26 26 20 78 66 65 72 2e 6e 54 ror") && xfer.nT
6920: 6f 6b 65 6e 3d 3d 32 20 29 7b 0a 20 20 20 20 20 oken==2 ){.
6930: 20 20 20 63 68 61 72 20 2a 7a 4d 73 67 20 3d 20 char *zMsg =
6940: 62 6c 6f 62 5f 74 65 72 6d 69 6e 61 74 65 28 26 blob_terminate(&
6950: 78 66 65 72 2e 61 54 6f 6b 65 6e 5b 31 5d 29 3b xfer.aToken[1]);
6960: 0a 20 20 20 20 20 20 20 20 64 65 66 6f 73 73 69 . defossi
6970: 6c 69 7a 65 28 7a 4d 73 67 29 3b 0a 20 20 20 20 lize(zMsg);.
6980: 20 20 20 20 62 6c 6f 62 5f 61 70 70 65 6e 64 66 blob_appendf
6990: 28 26 78 66 65 72 2e 65 72 72 2c 20 22 73 65 72 (&xfer.err, "ser
69a0: 76 65 72 20 73 61 79 73 3a 20 25 73 22 2c 20 7a ver says: %s", z
69b0: 4d 73 67 29 3b 0a 20 20 20 20 20 20 7d 65 6c 73 Msg);. }els
69c0: 65 0a 0a 20 20 20 20 20 20 2f 2a 20 55 6e 6b 6e e.. /* Unkn
69d0: 6f 77 6e 20 6d 65 73 73 61 67 65 20 2a 2f 0a 20 own message */.
69e0: 20 20 20 20 20 7b 0a 20 20 20 20 20 20 20 20 62 {. b
69f0: 6c 6f 62 5f 61 70 70 65 6e 64 66 28 26 78 66 65 lob_appendf(&xfe
6a00: 72 2e 65 72 72 2c 20 22 75 6e 6b 6e 6f 77 6e 20 r.err, "unknown
6a10: 63 6f 6d 6d 61 6e 64 3a 20 25 62 22 2c 20 26 78 command: %b", &x
6a20: 66 65 72 2e 61 54 6f 6b 65 6e 5b 30 5d 29 3b 0a fer.aToken[0]);.
6a30: 20 20 20 20 20 20 7d 0a 0a 20 20 20 20 20 20 69 }.. i
6a40: 66 28 20 62 6c 6f 62 5f 73 69 7a 65 28 26 78 66 f( blob_size(&xf
6a50: 65 72 2e 65 72 72 29 20 29 7b 0a 20 20 20 20 20 er.err) ){.
6a60: 20 20 20 66 6f 73 73 69 6c 5f 66 61 74 61 6c 28 fossil_fatal(
6a70: 22 25 62 22 2c 20 26 78 66 65 72 2e 65 72 72 29 "%b", &xfer.err)
6a80: 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 ;. }.
6a90: 62 6c 6f 62 61 72 72 61 79 5f 72 65 73 65 74 28 blobarray_reset(
6aa0: 78 66 65 72 2e 61 54 6f 6b 65 6e 2c 20 78 66 65 xfer.aToken, xfe
6ab0: 72 2e 6e 54 6f 6b 65 6e 29 3b 0a 20 20 20 20 20 r.nToken);.
6ac0: 20 62 6c 6f 62 5f 72 65 73 65 74 28 26 78 66 65 blob_reset(&xfe
6ad0: 72 2e 6c 69 6e 65 29 3b 0a 20 20 20 20 7d 0a 20 r.line);. }.
6ae0: 20 20 20 70 72 69 6e 74 66 28 22 5c 72 52 65 63 printf("\rRec
6af0: 65 69 76 65 64 3a 20 20 25 31 30 64 20 62 79 74 eived: %10d byt
6b00: 65 73 2c 20 25 35 64 20 6d 65 73 73 61 67 65 73 es, %5d messages
6b10: 2c 20 25 35 64 20 66 69 6c 65 73 20 28 25 64 2b , %5d files (%d+
6b20: 25 64 2b 25 64 29 5c 6e 22 2c 0a 20 20 20 20 20 %d+%d)\n",.
6b30: 20 20 20 20 20 20 20 62 6c 6f 62 5f 73 69 7a 65 blob_size
6b40: 28 26 72 65 63 76 29 2c 20 6e 4d 73 67 2c 0a 20 (&recv), nMsg,.
6b50: 20 20 20 20 20 20 20 20 20 20 20 78 66 65 72 2e xfer.
6b60: 6e 46 69 6c 65 52 63 76 64 20 2b 20 78 66 65 72 nFileRcvd + xfer
6b70: 2e 6e 44 65 6c 74 61 52 63 76 64 20 2b 20 78 66 .nDeltaRcvd + xf
6b80: 65 72 2e 6e 44 61 6e 67 6c 69 6e 67 46 69 6c 65 er.nDanglingFile
6b90: 2c 0a 20 20 20 20 20 20 20 20 20 20 20 20 78 66 ,. xf
6ba0: 65 72 2e 6e 46 69 6c 65 52 63 76 64 2c 20 78 66 er.nFileRcvd, xf
6bb0: 65 72 2e 6e 44 65 6c 74 61 52 63 76 64 2c 20 78 er.nDeltaRcvd, x
6bc0: 66 65 72 2e 6e 44 61 6e 67 6c 69 6e 67 46 69 6c fer.nDanglingFil
6bd0: 65 29 3b 0a 0a 20 20 20 20 62 6c 6f 62 5f 72 65 e);.. blob_re
6be0: 73 65 74 28 26 72 65 63 76 29 3b 0a 20 20 20 20 set(&recv);.
6bf0: 6e 43 79 63 6c 65 2b 2b 3b 0a 20 20 20 20 67 6f nCycle++;. go
6c00: 20 3d 20 30 3b 0a 0a 20 20 20 20 2f 2a 20 49 66 = 0;.. /* If
6c10: 20 77 65 20 72 65 63 65 69 76 65 64 20 6f 6e 65 we received one
6c20: 20 6f 72 20 6d 6f 72 65 20 66 69 6c 65 73 20 6f or more files o
6c30: 6e 20 74 68 65 20 70 72 65 76 69 6f 75 73 20 65 n the previous e
6c40: 78 63 68 61 6e 67 65 20 62 75 74 0a 20 20 20 20 xchange but.
6c50: 2a 2a 20 74 68 65 72 65 20 61 72 65 20 73 74 69 ** there are sti
6c60: 6c 6c 20 70 68 61 6e 74 6f 6d 73 2c 20 74 68 65 ll phantoms, the
6c70: 6e 20 67 6f 20 61 6e 6f 74 68 65 72 20 72 6f 75 n go another rou
6c80: 6e 64 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 6e nd.. */. n
6c90: 46 69 6c 65 52 65 63 76 20 3d 20 78 66 65 72 2e FileRecv = xfer.
6ca0: 6e 46 69 6c 65 52 63 76 64 20 2b 20 78 66 65 72 nFileRcvd + xfer
6cb0: 2e 6e 44 65 6c 74 61 52 63 76 64 20 2b 20 78 66 .nDeltaRcvd + xf
6cc0: 65 72 2e 6e 44 61 6e 67 6c 69 6e 67 46 69 6c 65 er.nDanglingFile
6cd0: 3b 0a 20 20 20 20 69 66 28 20 28 6e 46 69 6c 65 ;. if( (nFile
6ce0: 52 65 63 76 3e 30 20 7c 7c 20 6e 65 77 50 68 61 Recv>0 || newPha
6cf0: 6e 74 6f 6d 29 20 26 26 20 64 62 5f 65 78 69 73 ntom) && db_exis
6d00: 74 73 28 22 53 45 4c 45 43 54 20 31 20 46 52 4f ts("SELECT 1 FRO
6d10: 4d 20 70 68 61 6e 74 6f 6d 22 29 20 29 7b 0a 20 M phantom") ){.
6d20: 20 20 20 20 20 67 6f 20 3d 20 31 3b 0a 20 20 20 go = 1;.
6d30: 20 20 20 6d 78 50 68 61 6e 74 6f 6d 52 65 71 20 mxPhantomReq
6d40: 3d 20 6e 46 69 6c 65 52 65 63 76 2a 32 3b 0a 20 = nFileRecv*2;.
6d50: 20 20 20 20 20 69 66 28 20 6d 78 50 68 61 6e 74 if( mxPhant
6d60: 6f 6d 52 65 71 3c 32 30 30 20 29 20 6d 78 50 68 omReq<200 ) mxPh
6d70: 61 6e 74 6f 6d 52 65 71 20 3d 20 32 30 30 3b 0a antomReq = 200;.
6d80: 20 20 20 20 7d 0a 20 20 20 20 6e 4d 73 67 20 3d }. nMsg =
6d90: 20 30 3b 0a 20 20 20 20 78 66 65 72 2e 6e 46 69 0;. xfer.nFi
6da0: 6c 65 52 63 76 64 20 3d 20 30 3b 0a 20 20 20 20 leRcvd = 0;.
6db0: 78 66 65 72 2e 6e 44 65 6c 74 61 52 63 76 64 20 xfer.nDeltaRcvd
6dc0: 3d 20 30 3b 0a 20 20 20 20 78 66 65 72 2e 6e 44 = 0;. xfer.nD
6dd0: 61 6e 67 6c 69 6e 67 46 69 6c 65 20 3d 20 30 3b anglingFile = 0;
6de0: 0a 0a 20 20 20 20 2f 2a 20 49 66 20 77 65 20 68 .. /* If we h
6df0: 61 76 65 20 6f 6e 65 20 6f 72 20 6d 6f 72 65 20 ave one or more
6e00: 66 69 6c 65 73 20 71 75 65 75 65 64 20 74 6f 20 files queued to
6e10: 73 65 6e 64 2c 20 74 68 65 6e 20 67 6f 0a 20 20 send, then go.
6e20: 20 20 2a 2a 20 61 6e 6f 74 68 65 72 20 72 6f 75 ** another rou
6e30: 6e 64 20 0a 20 20 20 20 2a 2f 0a 20 20 20 20 69 nd . */. i
6e40: 66 28 20 78 66 65 72 2e 6e 46 69 6c 65 53 65 6e f( xfer.nFileSen
6e50: 74 2b 78 66 65 72 2e 6e 44 65 6c 74 61 53 65 6e t+xfer.nDeltaSen
6e60: 74 3e 30 20 29 7b 0a 20 20 20 20 20 20 67 6f 20 t>0 ){. go
6e70: 3d 20 31 3b 0a 20 20 20 20 7d 0a 20 20 7d 3b 0a = 1;. }. };.
6e80: 20 20 68 74 74 70 5f 63 6c 6f 73 65 28 29 3b 0a http_close();.
6e90: 20 20 64 62 5f 6d 75 6c 74 69 5f 65 78 65 63 28 db_multi_exec(
6ea0: 22 44 52 4f 50 20 54 41 42 4c 45 20 6f 6e 72 65 "DROP TABLE onre
6eb0: 6d 6f 74 65 22 29 3b 0a 20 20 64 62 5f 65 6e 64 mote");. db_end
6ec0: 5f 74 72 61 6e 73 61 63 74 69 6f 6e 28 30 29 3b _transaction(0);
6ed0: 0a 7d 0a .}.