home *** CD-ROM | disk | FTP | other *** search
/ PC Online 1997 August / PCO0897.ISO / filesbbs / os2 / plnk065.arj / PLNK065.ZIP / pilot-link.0.6.5 / sync-ical.c < prev    next >
Encoding:
C/C++ Source or Header  |  1997-05-23  |  19.9 KB  |  853 lines
  1. /* sync-ical.c:  Synchronize ical calendar file
  2.  *
  3.  * Copyright (c) 1996, Kenneth Albanowski
  4.  *
  5.  * This is free software, licensed under the GNU Public License V2.
  6.  * See the file COPYING for details.
  7.  */
  8.  
  9. /* This program is an experiment in synchronizing the Pilot datebook
  10.    database with an Ical database. It will not do anything useful for you.
  11.    Yet. If you are interested in exploring the syncronization process, read
  12.    lib/sync.c and sync-memodir.c */
  13.    
  14. /* At the moment, this file is an absolute mess, but it's functional, more
  15.    or less */
  16.  
  17. #include <stdio.h>
  18. #include <stdlib.h>
  19. #include <string.h>
  20. #include <stdarg.h>
  21. #include "pi-source.h"
  22. #include "pi-socket.h"
  23. #include "pi-sync.h"
  24. #include "pi-datebook.h"
  25. #include "pi-todo.h"
  26. #include "pi-dlp.h"
  27.  
  28. /* Set up a quick'n'dirty emulation of the Tcl interpreter commands */
  29. typedef struct {
  30.     int r, w;
  31.     char * result;
  32. } Tcl_Interp;
  33.  
  34. int Tcl_VarEval(Tcl_Interp * interp, ...) {
  35.     static char result[4096];
  36.     int l;
  37.     va_list args;
  38.     
  39.     va_start(args, interp);
  40.     
  41.     write(interp->w, "puts [catch {", 13);
  42.     for(;;) {
  43.         char * c = va_arg(args, char*);
  44.         if (!c)
  45.             break;
  46.         
  47.         write(interp->w, c, strlen(c));
  48.     }
  49.     write(interp->w, " } retval]\nputs -nonewline $retval\nflush stdout\n", 48);
  50.     
  51.     va_end(args);
  52.     
  53.     l = read(interp->r, result, 4096);
  54.     if (l<0)
  55.         l=0;
  56.     result[l] = '\0';
  57.     
  58.     interp->result = result;
  59.  
  60.     while(*interp->result != '\n')
  61.         interp->result++;
  62.         
  63.     *((interp->result)++) = '\0';
  64.     
  65.     return atoi(result);;
  66. }
  67.  
  68. int Tcl_Eval(Tcl_Interp * interp, char * cmd) {
  69.     return Tcl_VarEval(interp, cmd, NULL);
  70. }
  71.  
  72. char * tclquote(char * in) {
  73.   static char * buffer = 0;
  74.   char * out;
  75.   char * pos;
  76.   int len;
  77.  
  78.   len = 3;
  79.   pos = in;
  80.   while(*pos) {
  81.     if((*pos == '\\') || (*pos == '"') || (*pos == '[') || (*pos == '{') || (*pos == '$'))
  82.       len++;
  83.     len++;
  84.     pos++;
  85.   }
  86.  
  87.   if (buffer)
  88.     free(buffer);
  89.   buffer = (char*)malloc(len);
  90.   out = buffer;
  91.  
  92.   pos = in;
  93.   *out++ = '"';
  94.   while(*pos) {
  95.     if((*pos == '\\') || (*pos == '"') || (*pos == '[') || (*pos == '{') || (*pos == '$'))
  96.       *out++ = '\\';
  97.     *out++=*pos++;
  98.   }
  99.   *out++ = '"';
  100.   *out++ = '\0';
  101.  
  102.   return buffer;
  103. }
  104.  
  105.  
  106.  
  107. /* Define our own LocalRecord type. */
  108. struct LocalRecord {
  109.      StandardLocalRecord;
  110.      char * item; /* non-null and a name if an Ical item */
  111.      unsigned long deleted;  /* non-null if only a deletion ID */
  112. };
  113.                                         
  114. /* Define our own SyncAbs type */
  115. struct SyncAbs {
  116.      StandardSyncAbs;
  117.      /* items down here are equivalent of C++ class data.
  118.      Any information needed to talk to databases, etc., goes in here.
  119.       */
  120.     Tcl_Interp * ical;
  121.     char * cal;
  122.     int todo; /* Are we interested in todos or memos? */
  123. };
  124.  
  125. /* Get a Pilot ID for a local record, or 0 if no Pilot ID has been set. Any
  126.    local ID mechanism is not relevent, only IDs given by the Pilot. */
  127. unsigned long GetPilotID(SyncAbs * thisSA,LocalRecord * Local) {
  128.     char * var;
  129.     /*char id[10];*/
  130.  
  131.     if (Local->deleted)
  132.         return Local->deleted;
  133.         
  134.     Tcl_VarEval(thisSA->ical, 
  135.       "set result 0\n",
  136.       "catch { set result [", Local->item, " option sync_id]}\n",
  137.       "set result",
  138.       NULL);
  139.  
  140.         if ((thisSA->ical->result[0] - '0') != thisSA->todo)
  141.           return 0;
  142.     
  143.     var = thisSA->ical->result+1;
  144.     
  145.     return atoi(var);
  146. }
  147.  
  148. /* Set the ID on a local record to match a given Pilot ID. */
  149. int SetPilotID(SyncAbs * thisSA,LocalRecord * Local, unsigned long ID) {
  150.     char buf[40];
  151.     sprintf(buf,"%d%lu", thisSA->todo?1:0, ID);
  152.     Tcl_VarEval(thisSA->ical, Local->item, " option sync_id ",buf,NULL);
  153.     return 1;
  154. }
  155.  
  156. /* Given a PilotRecord, try and find a local record with a matching ID */
  157. int MatchRecord(SyncAbs * thisSA,  LocalRecord ** Local, PilotRecord * p) {
  158.     static LocalRecord lr;
  159.     char buf[40];
  160.     sprintf(buf,"%d%lu", thisSA->todo?1:0, p->ID);
  161.     
  162.     /* Check active items */
  163.     Tcl_VarEval(thisSA->ical,
  164.       "set result \"\"\n", 
  165.       thisSA->cal, " incalendar [", thisSA->cal, " main] item {\n",
  166.       "  catch { \n",
  167.       "    if {[string compare [$item option sync_id] \"", buf, "\"]==0} {\n",
  168.       "      set result $item\n",
  169.       "    }\n",
  170.       "  }\n",
  171.       "}\n",
  172.       "set result",
  173.           NULL);
  174.     
  175.     if (strlen(thisSA->ical->result)) {
  176.         *Local = &lr;
  177.         lr.item = strdup(thisSA->ical->result);
  178.         lr.deleted = 0;
  179.         return 1;
  180.     }
  181.     
  182.     /* Check deleted items */
  183.     Tcl_VarEval(thisSA->ical,
  184.           "set result \"\"\n",
  185.           "catch {\n",
  186.           "  set deleted [",thisSA->cal," option deleted]\n",
  187.           "  foreach item $deleted {\n",
  188.           "    if {[string compare $item  \"",buf,"\"]==0} {\n",
  189.           "      set result $item\n",
  190.           "      break\n",
  191.           "    }\n",
  192.           "  }\n",
  193.           "}\n",
  194.           "set result",
  195.           NULL);
  196.           
  197.     if (strlen(thisSA->ical->result)) {
  198.         *Local = &lr;
  199.         lr.item = 0;
  200.         lr.deleted = atoi(thisSA->ical->result+1);
  201.         return 1;
  202.     } else {
  203.         *Local = 0;
  204.         return 0;
  205.     }
  206. }
  207.  
  208. /* Free up the LocalRecord returned by MatchRecord */
  209. int FreeMatch(SyncAbs * thisSA,LocalRecord ** Local) {
  210.     *Local = 0;
  211.     return 0;
  212. }
  213.  
  214.  
  215. /* Iterate over all LocalRecords, in arbitrary order */
  216. int Iterate(SyncAbs * thisSA, LocalRecord ** Local) {
  217.     static LocalRecord lr;
  218.     
  219.     if (!*Local) {
  220.       Tcl_VarEval(thisSA->ical,
  221.             "set active {}\n",
  222.             thisSA->cal," incalendar [", thisSA->cal, " main] item {\n",
  223.             "  # some dohicky to make sure record's todo matches thisSA->todo\n",
  224.             "  lappend active $item\n",
  225.             "}\n",
  226.             "set deleted {}\n",
  227.             "catch {\n",
  228.             "  set deleted [",thisSA->cal," option deleted]\n",
  229.             "}\n",
  230.             NULL);
  231.     }
  232.     
  233.     Tcl_VarEval(thisSA->ical,
  234.       "set result {}\n",
  235.       "if {[llength $active]>0} {\n",
  236.       "  set result [lindex $active 0]\n",
  237.       "  set active [lreplace 1 end]\n",
  238.       "}\n",
  239.       "set result",
  240.       NULL);
  241.     
  242.     if (strlen(thisSA->ical->result)) {
  243.         *Local = &lr;
  244.         lr.item = strdup(thisSA->ical->result);
  245.         lr.deleted = 0;
  246.         return 1;
  247.     }
  248.  
  249.     Tcl_VarEval(thisSA->ical,
  250.       "set result {}\n",
  251.       "if {[llength $deleted]>0} {\n",
  252.       "  set result [lindex $deleted 0]\n",
  253.       "  set deleted [lreplace $deleted 1 end]\n",
  254.       "}\n",
  255.       "set result",
  256.       NULL);
  257.  
  258.     
  259.     if (strlen(thisSA->ical->result)) {
  260.         *Local = &lr;
  261.         lr.item = 0;
  262.         lr.deleted = atoi(thisSA->ical->result);
  263.         return 1;
  264.     }
  265.  
  266.     return *Local!=0;
  267. }
  268.  
  269. /* Iterate over local records of a specified type. */
  270. int IterateSpecific(SyncAbs * thisSA, LocalRecord ** Local, int flag, int archived)
  271. {
  272.     static LocalRecord lr;
  273.     
  274.     if (!*Local) {
  275.       Tcl_VarEval(thisSA->ical,
  276.         "set active {}\n",
  277.         thisSA->cal," incalendar [", thisSA->cal, " main] item {\n",
  278.         "  lappend active $item\n",
  279.         "}\n",
  280.         "set deleted {}\n",
  281.         "catch {\n",
  282.         "  set deleted [",thisSA->cal," option deleted]\n",
  283.         "}\n",
  284.         NULL);
  285.     }
  286.     
  287.     Tcl_VarEval(thisSA->ical,
  288.       "set result {}\n",
  289.       "if {[llength $active]>0} {\n",
  290.       "  set result [lindex $active 0]\n",
  291.       "  set active [lreplace 1 end]\n",
  292.       "}\n",
  293.       "set result",
  294.       NULL);
  295.     
  296.     if (strlen(thisSA->ical->result)) {
  297.         *Local = &lr;
  298.         lr.item = strdup(thisSA->ical->result);
  299.         lr.deleted = 0;
  300.         return 1;
  301.     }
  302.  
  303.     Tcl_VarEval(thisSA->ical,
  304.       "set result {}\n",
  305.       "if {[llength $deleted]>0} {\n",
  306.       "  set result [lindex $deleted 0]\n",
  307.       "  set deleted [lreplace $deleted 1 end]\n",
  308.       "}\n",
  309.       "set result",
  310.       NULL);
  311.  
  312.     
  313.     if (strlen(thisSA->ical->result)) {
  314.         *Local = &lr;
  315.         lr.item = 0;
  316.         lr.deleted = atoi(thisSA->ical->result);
  317.         return 1;
  318.     }
  319.  
  320.     return *Local!=0;
  321. }
  322.  
  323. /* Given a PilotRecord, store it in the local database */
  324. int StoreRemote(SyncAbs * thisSA,PilotRecord* p) {
  325.     struct Appointment a;
  326.     int j;
  327.     char buf[256];
  328.     
  329.     unpack_Appointment(&a, p->record, p->length);
  330.     
  331.     if (a.event) {
  332.       Tcl_Eval(thisSA->ical,"set i [notice]");
  333.  
  334.     } else {
  335.       int start,end;
  336.  
  337.       Tcl_Eval(thisSA->ical,"set i [appointment]");
  338.       
  339.       start = a.begin.tm_hour*60 + a.begin.tm_min;
  340.       end   = a.end.tm_hour*60 + a.end.tm_min;
  341.  
  342.       sprintf(buf, "%d", start);
  343.       Tcl_VarEval(thisSA->ical,"$i starttime ",buf, NULL);
  344.       sprintf(buf, "%d", end-start+1);
  345.       Tcl_VarEval(thisSA->ical,"$i length ",buf, NULL);
  346.     }
  347.     sprintf(buf, "%lu", p->ID);
  348.         Tcl_VarEval(thisSA->ical,"$i option sync_id ",buf, NULL);
  349.     
  350.         Tcl_VarEval(thisSA->ical,"$i text ",tclquote(a.description), NULL);
  351.     
  352.     sprintf(buf,"set begin [date make %d %d %d]\n", a.begin.tm_mday,a.begin.tm_mon+1,a.begin.tm_year+1900);
  353.     Tcl_Eval(thisSA->ical,buf);
  354.     
  355.     if (a.repeatFreq) {
  356.       if (a.repeatType == repeatDaily) {
  357.         sprintf(buf,"$i dayrepeat %d $begin", a.repeatFreq);
  358.         Tcl_Eval(thisSA->ical,buf);
  359.       } else if(a.repeatType == repeatMonthlyByDate) {
  360.         sprintf(buf,"$i month_day %d $begin %d", a.begin.tm_mon+1,a.repeatFreq);
  361.         Tcl_Eval(thisSA->ical,buf);
  362.       } else if(a.repeatType == repeatMonthlyByDay) {
  363.         if (a.repeatOn>=domLastSun) {
  364.           sprintf(buf,"$i month_last_week_day %d 1 $begin %d\n", a.repeatOn % 7 + 1,
  365.                                                         a.repeatFreq);
  366.           Tcl_Eval(thisSA->ical,buf);
  367.         } else {
  368.           sprintf(buf,"$i month_week_day %d %d $begin %d\n", a.repeatOn % 7 + 1,
  369.                                                         a.repeatOn / 7 + 1,
  370.                                                         a.repeatFreq);
  371.           Tcl_Eval(thisSA->ical,buf);
  372.         }
  373.       } else if(a.repeatType == repeatWeekly) {
  374.         strcpy(buf,"$i weekdays ");
  375.             if(a.repeatOn & 1)
  376.               strcat(buf,"1 ");
  377.             if(a.repeatOn & 2)
  378.               strcat(buf,"2 ");
  379.             if(a.repeatOn & 4)
  380.               strcat(buf,"3 ");
  381.             if(a.repeatOn & 8)
  382.               strcat(buf,"4 ");
  383.             if(a.repeatOn & 16)
  384.               strcat(buf,"5 ");
  385.             if(a.repeatOn & 32)
  386.               strcat(buf,"6 ");
  387.             if(a.repeatOn & 64)
  388.               strcat(buf,"7 ");
  389.             strcat(buf,"\n");
  390.             Tcl_Eval(thisSA->ical,buf);
  391.       } else if(a.repeatType == repeatYearly) {
  392.         sprintf(buf,"$i monthrepeat %d $begin\n", 12 * a.repeatFreq);
  393.         Tcl_Eval(thisSA->ical,buf);
  394.       }
  395.       Tcl_Eval(thisSA->ical,"$i start $begin\n");
  396.       if (!a.repeatForever) {
  397.         sprintf(buf,"$i finish [date make %d %d %d]\n", a.repeatEnd.tm_mday, a.repeatEnd.tm_mon+1, 
  398.                                                    a.repeatEnd.tm_year+1900);
  399.         Tcl_Eval(thisSA->ical,buf);
  400.       }
  401.       if (a.exceptions)
  402.         for (j=0;j<a.exceptions;j++) {
  403.           sprintf(buf,"$i deleteon [date make %d %d %d]\n", a.exception[j].tm_mday,
  404.                                                        a.exception[j].tm_mon+1,
  405.                                                        a.exception[j].tm_year+1900);
  406.           Tcl_Eval(thisSA->ical,buf);
  407.         }
  408.     } else 
  409.           Tcl_Eval(thisSA->ical,"$i date $begin\n");
  410.     
  411.     Tcl_VarEval(thisSA->ical,thisSA->cal," add $i\n",NULL);
  412.  
  413.     free_Appointment(&a);
  414.  
  415.     return 0;    
  416. }
  417.  
  418.  
  419. /* Delete all local records */
  420. int DeleteAll(SyncAbs * thisSA) {
  421.  
  422.     Tcl_VarEval(thisSA->ical,
  423.       thisSA->cal," incalendar [", thisSA->cal, " main] item {\n",
  424.       "  $item delete\n",
  425.       "}\n",
  426.       thisSA->cal," option deleted {}",
  427.       NULL);
  428.     return 0;
  429. }
  430.  
  431.  
  432.  
  433. /*===========================================================*/
  434. #if 0
  435. /*  These are the important functions below. They implement the interface that
  436.     the abstract synchronization layer invokes */
  437.  
  438. /* Get a Pilot ID for a local record, or 0 if no Pilot ID has been set. Any
  439.    local ID mechanism is not relevent, only IDs given by the Pilot. */
  440. unsigned long GetPilotID(SyncAbs * thisSA,LocalRecord * Local) {
  441.     return Local->ID;
  442.     return 1;
  443. }
  444.  
  445. /* Set the ID on a local record to match a given Pilot ID. */
  446. int SetPilotID(SyncAbs * thisSA,LocalRecord * Local, unsigned long ID) {
  447.     Local->ID = ID;
  448.     return 1;
  449. }
  450.  
  451. /* Given a PilotRecord, try and find a local record with a matching ID */
  452. int MatchRecord(SyncAbs * thisSA,  LocalRecord ** Local, PilotRecord * p) {
  453.     LocalRecord * m = memos;
  454.     while(m) {
  455.         if(m->ID == p->ID)
  456.             break;
  457.         m=m->next;
  458.     }
  459.     if(m)
  460.         *Local = m;
  461.     else
  462.         *Local = 0;
  463.     
  464.     return 1;
  465. }
  466.  
  467. /* Free up the LocalRecord returned by MatchRecord */
  468. int FreeMatch(SyncAbs * thisSA,LocalRecord ** Local) {
  469.     *Local = 0;
  470.     return 0;
  471. }
  472.  
  473. /* Iterate over all LocalRecords, in arbitrary order */
  474. int Iterate(SyncAbs * thisSA, LocalRecord ** Local) {
  475.     LocalRecord * m = *Local;
  476.     if( !m) {
  477.         m = memos;
  478.     } else {
  479.         m=m->next;
  480.     }
  481.     *Local = m;
  482.     return m!=0;
  483. }
  484.  
  485. /* Iterate over local records of a specified type. */
  486. int IterateSpecific(SyncAbs * thisSA, LocalRecord ** Local, int flag, int archived) {
  487.     LocalRecord * m = *Local;
  488.     if( !m) {
  489.         m = memos;
  490.     } else {
  491.         m=m->next;
  492.     }
  493.     while(m) {
  494.             if(archived) {
  495.               if(m->archived)
  496.                 break;
  497.             } else {
  498.           if(m->attr == flag)
  499.             break;
  500.         }
  501.         m=m->next;
  502.     }
  503.     *Local = m;
  504.     return m!=0;
  505. }
  506.  
  507. /* Set status of local record */
  508. int SetStatus(SyncAbs * thisSA,LocalRecord * Local, int status) {
  509.     Local->attr = status;
  510.     return 0;
  511. }
  512.  
  513. /* There is no GetStatus, the abstract layer uses Local->attr */
  514.  
  515. /* Set archival status of local record */
  516. int SetArchived(SyncAbs * thisSA,LocalRecord * Local,int archived) {
  517.         Local->archived = archived;
  518.     return 0;
  519. }
  520.  
  521. /* There is no GetStatus, the abstract layer uses Local->archived */
  522.  
  523. /* Given a PilotRecord, store it in the local database */
  524. int StoreRemote(SyncAbs * thisSA,PilotRecord* p) {
  525.     LocalRecord * m;
  526.     int h;
  527.     struct stat stbuf;
  528.     
  529.     if(p->ID != 0) {
  530.         /* replace record */
  531.         m = memos;
  532.         while(m) {
  533.             if(m->ID == p->ID)
  534.                 break;
  535.             m=m->next;
  536.         }
  537.         if (m) {
  538.             h = open(filename(m->name),O_WRONLY|O_CREAT|O_TRUNC,0666);
  539.             write(h, p->record, p->length-1);
  540.             write(h, "\n", 1);
  541.             close(h);
  542.             stat(filename(m->name),&stbuf);
  543.             m->mtime = stbuf.st_mtime;
  544.             return 0;
  545.         }
  546.     }
  547.     /* new record */
  548.     m = (LocalRecord*)malloc(sizeof(LocalRecord));
  549.     m->ID = p->ID;
  550.     m->attr = p->attr;
  551.     m->secret = p->secret;
  552.     
  553.     strcpy(m->name, newfilename(p));
  554.     
  555.     m->next = memos;
  556.     memos = m;
  557.  
  558.     h = open(filename(m->name),O_WRONLY|O_CREAT|O_TRUNC,0666);
  559.     write(h, p->record, p->length-1);
  560.     write(h, "\n", 1);
  561.     close(h);
  562.  
  563.     stat(filename(m->name),&stbuf);
  564.     m->mtime = stbuf.st_mtime;
  565.     
  566.     return 0;    
  567. }
  568.  
  569. /* Given a local record, construct a PilotRecord suitable for transmission
  570. to a Pilot */
  571. PilotRecord * Transmit(SyncAbs* thisSA ,LocalRecord* Local) {
  572.         static PilotRecord p;
  573.     int h = open(filename(Local->name),O_RDONLY);
  574.     
  575.     struct stat statbuf;
  576.     stat(filename(Local->name),&statbuf);
  577.     p.length = statbuf.st_size+1;
  578.     p.record = (unsigned char*)malloc(p.length);
  579.     read(h, p.record, p.length-1);
  580.     p.record[p.length-1] = '\0';
  581.     close(h);
  582.     
  583.     p.category = 0;
  584.     p.attr = Local->attr;
  585.     p.archived = Local->archived;
  586.     p.secret = Local->secret;
  587.     
  588.     return &p;
  589. }
  590.  
  591. /* Free PilotRecord created by Transmit */
  592. int FreeTransmit(SyncAbs* thisSA,LocalRecord* Local,PilotRecord* Remote) {
  593.     free(Remote->record);
  594.     return 0;
  595. }
  596.  
  597. /* Find a local backup record and compare it to the pilot record for inequality */
  598. int CompareBackup(SyncAbs * thisSA, LocalRecord* m, PilotRecord* p) {
  599.     char buffer[0xffff];
  600.     int r,len;
  601.  
  602.       r = open(backupname(m->name),O_RDONLY);
  603.       
  604.       if (r<0)
  605.         return -1; /* "less", arbitrary */
  606.       
  607.       len = read(r,buffer,0xffff);
  608.     close(r);
  609.     
  610.     if(len != p->length)
  611.         return -1; /* "less", arbitrary */
  612.  
  613.     if(buffer[len-1] == '\n')
  614.         buffer[len-1] = '\0';
  615.     
  616.     return memcmp(buffer, p->record, len);
  617. }
  618.  
  619. /* Compare a local record and pilot record for inequality */
  620. int Compare(SyncAbs * thisSA, LocalRecord * m, PilotRecord* p) {
  621.     char buffer[0xffff];
  622.       int r = open(filename(m->name),O_RDONLY);
  623.       int len = read(r,buffer,0xffff);
  624.     close(r);
  625.  
  626.     if(len != p->length)
  627.         return -1; /* "less", arbitrary */
  628.  
  629.     if(buffer[len-1] == '\n')
  630.         buffer[len-1] = '\0';
  631.     
  632.     return memcmp(buffer, p->record, len);
  633. }
  634.  
  635. /* Delete all local records */
  636. int DeleteAll(SyncAbs * thisSA) {
  637.     while(memos) {
  638.         LocalRecord * m = memos;
  639.         memos = memos->next;
  640.         if(m->attr != RecordDeleted) {
  641.             unlink(filename(m->name));
  642.         }
  643.         free(m);
  644.     }
  645.     return 0;
  646. }
  647.  
  648. /* Do a local purge, deleting all records marked Deleted, and
  649.    archiving all records marked for archiving */
  650. int Purge(SyncAbs * thisSA) {
  651.     LocalRecord * prev = 0;
  652.     LocalRecord * m = memos, *next;
  653.     while(m) {
  654.         next = m->next;
  655.         if((m->attr == RecordDeleted) || (m->archived)) {
  656.             unlink(filename(m->name));
  657.             if(prev)
  658.                 prev->next = next;
  659.             else
  660.                 memos=next;
  661.             free(m);
  662.         } else
  663.             prev = m;
  664.         m = next;
  665.     }
  666.     return 0;
  667. }
  668.  
  669. /* Add remote record to archive. l is non-NULL if there is a matching local record */
  670. int ArchiveRemote(SyncAbs * s, LocalRecord * l, PilotRecord * p) {
  671.     char name[256];
  672.     int h;
  673.     strcpy(name,"Memos/Archive/memoXXXXXX");
  674.  
  675.     h = open(newarchivename(p,l),O_WRONLY|O_CREAT|O_TRUNC,0666);
  676.     write(h, p->record, p->length-1);
  677.     write(h, "\n", 1);
  678.     close(h);
  679.     
  680.     return 0;
  681. }
  682.  
  683. #endif
  684. /*===========================================================*/
  685.                                                                                          
  686.                                                                                          
  687. /*typedef struct{
  688.     char calname[40];
  689.     int r,w;
  690. } LocalData;
  691.  
  692. typedef struct {
  693.     char recname[40];
  694.     long PilotID;
  695. } LocalRecord;*/
  696.  
  697. void dosend(char*text, int w) {
  698.     write(w,text,strlen(text));
  699.     write(w,"flush stdout\n",13);
  700. }
  701.  
  702. void doread(char*buffer, int r) {
  703.     int l = read(r,buffer,4096);
  704.     buffer[l] = 0;
  705. }
  706.  
  707. int main(int argc, char *argv[])
  708. {
  709.   struct pi_sockaddr addr;
  710.   int db;
  711.   int sd;
  712.   struct PilotUser U;
  713.   int in[2], out[2];
  714.   int ret;
  715.   struct SyncAbs abs;
  716.   /*struct SyncAbs abs;*/
  717. /*   = {MatchRecord, IsNew, IsModified, IsArchived, IsNothing,
  718.                         AppendLocal, AppendArchive, StartIterator, NextIterator};*/
  719.   /*LocalData ld;
  720.   LocalRecord *lrp;*/
  721.   Tcl_Interp ical;
  722.  
  723. #if 0
  724.   /* Set up abstraction structure */  
  725.   abs.MatchRecord = MatchRecord;
  726.   abs.Iterate = Iterate;
  727.   abs.IterateSpecific = IterateSpecific;
  728.   abs.SetStatus = SetStatus;
  729.   abs.SetArchived = SetArchived;
  730.   abs.SetPilotID = SetPilotID;
  731.   abs.GetPilotID = GetPilotID;
  732.   abs.StoreRemote = StoreRemote;
  733.   abs.ArchiveLocal = 0;             /* missing */
  734.   abs.ClearStatusArchiveLocal = 0;  /* likewise */
  735.   abs.ArchiveRemote = ArchiveRemote;
  736.   abs.DeleteAll = DeleteAll;
  737.   abs.Purge = Purge;
  738.   abs.CompareBackup = CompareBackup;
  739.   abs.Compare = Compare;
  740.   abs.Transmit = Transmit;
  741.   abs.FreeTransmit = FreeTransmit;
  742. #endif
  743.   abs.DeleteAll = DeleteAll;
  744.   abs.StoreRemote = StoreRemote;
  745.  
  746. #if 0  
  747.   abs.MatchRecord = MatchRecord;
  748.   abs.IsNew = IsNew;
  749.   abs.GetPilotID = GetPilotID;
  750.   abs.IsModified = IsModified;
  751.   abs.IsArchived = IsArchived;
  752.   abs.IsNothing = IsNothing;
  753.   abs.AppendLocal = AppendLocal;
  754.   abs.AppendArchive = AppendArchive;
  755. #endif  
  756.  
  757.   if (argc < 3) {
  758.     fprintf(stderr,"usage:%s %s calfile # Calfile will be overwritten!\n",argv[0],TTYPrompt);
  759.     exit(2);
  760.   }
  761.   if (!(sd = pi_socket(PI_AF_SLP, PI_SOCK_STREAM, PI_PF_PADP))) {
  762.     perror("pi_socket");
  763.     exit(1);
  764.   }
  765.  
  766.   pipe(&in[0]);
  767.   pipe(&out[0]);
  768.   
  769.   if(!fork()) {
  770.       close(in[1]);
  771.       close(out[0]);
  772.       dup2(in[0],fileno(stdin));
  773.       dup2(out[1],fileno(stdout));
  774.       system("ical -f -");
  775.       exit(0);
  776.   }
  777.   
  778.   ical.w = in[1];
  779.   ical.r = out[0];
  780.   
  781.   /*ical = Tcl_CreateInterp();
  782.   
  783.   app_init(ical);*/
  784.   
  785.   Tcl_VarEval(&ical, "calendar calmain ",argv[2]);
  786.  
  787.   abs.ical = &ical;
  788.   abs.cal = "calmain";
  789.   
  790.   addr.pi_family = PI_AF_SLP;
  791.   addr.pi_port = 3;
  792.   strcpy(addr.pi_device,argv[1]);
  793.   
  794.   ret = pi_bind(sd, &addr, sizeof(addr));
  795.   if(ret == -1) {
  796.     perror("pi_bind");
  797.     exit(1);
  798.   }
  799.  
  800.   ret = pi_listen(sd,1);
  801.   if(ret == -1) {
  802.     perror("pi_listen");
  803.     exit(1);
  804.   }
  805.  
  806.   sd = pi_accept(sd, 0, 0);
  807.   if(sd == -1) {
  808.     perror("pi_accept");
  809.     exit(1);
  810.   }
  811.  
  812.   /* Ask the pilot who it is. */
  813.   dlp_ReadUserInfo(sd,&U);
  814.   
  815.   /* Tell user (via Pilot) that we are starting things up */
  816.   dlp_OpenConduit(sd);
  817.   
  818.   /* Open the Datebook's database, store access handle in db */
  819.   if(dlp_OpenDB(sd, 0, dlpOpenReadWrite, "DatebookDB", &db) < 0) {
  820.     puts("Unable to open DatebookDB");
  821.     dlp_AddSyncLogEntry(sd, "Unable to open DatebookDB.\n");
  822.     pi_close(sd);
  823.     exit(1);
  824.   }
  825.   
  826.   CopyFromRemote(sd, db, &abs);
  827.   
  828. /*  SyncDB(sd, &db, &abs, &ld);*/
  829.  
  830.   /* Close the database */
  831.   dlp_CloseDB(sd, db);
  832.   
  833.   dlp_ReadUserInfo(sd, &U);
  834.   
  835.   U.lastSyncPC = 0xDEADBEEF;
  836.     
  837.   dlp_WriteUserInfo(sd, &U);
  838.         
  839.  
  840.   dlp_AddSyncLogEntry(sd, "Read datebook from Pilot.\n");
  841.   
  842.   Tcl_VarEval(&ical,abs.cal," save [",abs.cal," main]",NULL);
  843.  
  844.  
  845.   close(ical.w);
  846.   close(ical.r);
  847.  
  848.   pi_close(sd);  
  849.   
  850.   return 0;
  851. }
  852.  
  853.