X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~yarrgweb/git?a=blobdiff_plain;f=yarrg%2Fcommod-email-processor;h=b395aa8d851fc1ede7bc385968b20b65d8758eca;hb=efc8497c2414dfded724d7181e11df53b947e387;hp=bf42c0d65ef4b8344f29963de36080b35f664535;hpb=7d2fec305c9bdc622a41a343332331b25472fa20;p=ypp-sc-tools.web-live.git

diff --git a/yarrg/commod-email-processor b/yarrg/commod-email-processor
index bf42c0d..b395aa8 100755
--- a/yarrg/commod-email-processor
+++ b/yarrg/commod-email-processor
@@ -25,25 +25,6 @@
 # are used without permission.  This program is not endorsed or
 # sponsored by Three Rings.
 
-# Emails are:
-#  multipart/mixed, containing
-#   text/plain; name="metadata"; charset="utf-8"
-#   Content-Disposition: inline; filename="metadata"
-#     ocean\t<ocean>		canonical mixed case
-#     island\t<island>		canonical mixed case
-#     timestamp\t<digits>	time_t (non-leap secs since start of 1970 UTC)
-#     clientname\t<cname>	may contain spaces
-#     clientversion\t<cversion>	may contain spaces
-#     clientfixes\t<cfixes>	space-delimited list
-#     clientspec\t<cspec>	<cname>\t<cversion>\t<cfixes>
-#     servername\t<sname>	may contain spaces
-#     serverversion\t<sversion>	may contain spaces
-#     serverfixes\t<sfixes>	space-delimited list
-#     serverspec\t<sspec>	<sname>\t<serverversion>\t<serverfixes>
-#   application/octet-stream; name="deduped.tsv.gz"
-#   Content-Disposition: attachment; filename="deduped.tsv.gz"
-#     <base64>
-
 use strict (qw(vars));
 
 use POSIX;
@@ -58,7 +39,7 @@ BEGIN {
 use Commods;
 use CommodsDatabase;
 
-setlocale(LC_CTYPE, "en_GB.UTF-8");
+set_ctype_utf8();
 my $parser= new MIME::Parser;
 our $entity;
 
@@ -117,7 +98,9 @@ sub main () {
     db_setocean($md{'ocean'});
     my $dbfn= db_filename();
     (stat $dbfn) or die "stat database $dbfn failed $!\n";
+    db_writer();
     db_connect();
+    db_onconflict(sub { print STDERR "temporary failure: @_\n"; exit 75; });
 
     my ($islandid) = $dbh->selectrow_array(
               "SELECT islands.islandid
@@ -206,7 +189,7 @@ sub main () {
 
     pipethrough_run_finish($pt, 'gunzip <$deduped_tsv.gz');
 
-    print "\n";
+#    print "\n";
     $dbh->commit();
 
     # select * from ((buy natural join commods) natural join stalls) natural join islands;