Project

General

Profile

Download (28.9 KB) Statistics
| Branch: | Tag: | Revision:

magiccube / src / main / java / org / distorted / external / RubikNetwork.java @ 66935886

1
///////////////////////////////////////////////////////////////////////////////////////////////////
2
// Copyright 2019 Leszek Koltunski                                                               //
3
//                                                                                               //
4
// This file is part of Magic Cube.                                                              //
5
//                                                                                               //
6
// Magic Cube is free software: you can redistribute it and/or modify                            //
7
// it under the terms of the GNU General Public License as published by                          //
8
// the Free Software Foundation, either version 2 of the License, or                             //
9
// (at your option) any later version.                                                           //
10
//                                                                                               //
11
// Magic Cube is distributed in the hope that it will be useful,                                 //
12
// but WITHOUT ANY WARRANTY; without even the implied warranty of                                //
13
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                                 //
14
// GNU General Public License for more details.                                                  //
15
//                                                                                               //
16
// You should have received a copy of the GNU General Public License                             //
17
// along with Magic Cube.  If not, see <http://www.gnu.org/licenses/>.                           //
18
///////////////////////////////////////////////////////////////////////////////////////////////////
19

    
20
package org.distorted.external;
21

    
22
import java.io.BufferedReader;
23
import java.io.IOException;
24
import java.io.InputStream;
25
import java.io.InputStreamReader;
26
import java.net.HttpURLConnection;
27
import java.net.URL;
28
import java.net.UnknownHostException;
29
import java.security.MessageDigest;
30
import java.security.NoSuchAlgorithmException;
31

    
32
import android.content.Context;
33
import android.content.pm.PackageInfo;
34
import android.content.pm.PackageManager;
35
import android.graphics.Bitmap;
36
import android.graphics.BitmapFactory;
37

    
38
import androidx.fragment.app.FragmentActivity;
39

    
40
import org.distorted.library.main.DistortedLibrary;
41
import org.distorted.objectlib.json.JsonWriter;
42
import org.distorted.objects.RubikObjectList;
43

    
44
import static org.distorted.objects.RubikObjectList.MAX_LEVEL;
45
import static org.distorted.main.RubikActivity.SHOW_DOWNLOADED_DEBUG;
46

    
47
///////////////////////////////////////////////////////////////////////////////////////////////////
48

    
49
public class RubikNetwork
50
  {
51
  public interface ScoresReceiver
52
    {
53
    void receive(String[][][] country, String[][][] name, float[][][] time);
54
    void message(String mess);
55
    void error(String error);
56
    }
57

    
58
  public interface IconReceiver
59
    {
60
    void iconDownloaded(int ordinal, Bitmap bitmap, boolean downloaded);
61
    }
62

    
63
  public interface Updatee
64
    {
65
    void receiveUpdate(RubikUpdates update);
66
    void errorUpdate();
67
    }
68

    
69
  public interface Downloadee
70
    {
71
    void jsonDownloaded();
72
    }
73

    
74
  public static final int MAX_PLACES = 10;
75

    
76
  private static final int REND_ADRENO= 0;
77
  private static final int REND_MALI  = 1;
78
  private static final int REND_POWER = 2;
79
  private static final int REND_OTHER = 3;
80

    
81
  private static final int DEBUG_RUNNING = 1;
82
  private static final int DEBUG_SUCCESS = 2;
83
  private static final int DEBUG_FAILURE = 3;
84

    
85
  private final String[] hex = {
86
    "%00", "%01", "%02", "%03", "%04", "%05", "%06", "%07",
87
    "%08", "%09", "%0a", "%0b", "%0c", "%0d", "%0e", "%0f",
88
    "%10", "%11", "%12", "%13", "%14", "%15", "%16", "%17",
89
    "%18", "%19", "%1a", "%1b", "%1c", "%1d", "%1e", "%1f",
90
    "%20", "%21", "%22", "%23", "%24", "%25", "%26", "%27",
91
    "%28", "%29", "%2a", "%2b", "%2c", "%2d", "%2e", "%2f",
92
    "%30", "%31", "%32", "%33", "%34", "%35", "%36", "%37",
93
    "%38", "%39", "%3a", "%3b", "%3c", "%3d", "%3e", "%3f",
94
    "%40", "%41", "%42", "%43", "%44", "%45", "%46", "%47",
95
    "%48", "%49", "%4a", "%4b", "%4c", "%4d", "%4e", "%4f",
96
    "%50", "%51", "%52", "%53", "%54", "%55", "%56", "%57",
97
    "%58", "%59", "%5a", "%5b", "%5c", "%5d", "%5e", "%5f",
98
    "%60", "%61", "%62", "%63", "%64", "%65", "%66", "%67",
99
    "%68", "%69", "%6a", "%6b", "%6c", "%6d", "%6e", "%6f",
100
    "%70", "%71", "%72", "%73", "%74", "%75", "%76", "%77",
101
    "%78", "%79", "%7a", "%7b", "%7c", "%7d", "%7e", "%7f",
102
    "%80", "%81", "%82", "%83", "%84", "%85", "%86", "%87",
103
    "%88", "%89", "%8a", "%8b", "%8c", "%8d", "%8e", "%8f",
104
    "%90", "%91", "%92", "%93", "%94", "%95", "%96", "%97",
105
    "%98", "%99", "%9a", "%9b", "%9c", "%9d", "%9e", "%9f",
106
    "%a0", "%a1", "%a2", "%a3", "%a4", "%a5", "%a6", "%a7",
107
    "%a8", "%a9", "%aa", "%ab", "%ac", "%ad", "%ae", "%af",
108
    "%b0", "%b1", "%b2", "%b3", "%b4", "%b5", "%b6", "%b7",
109
    "%b8", "%b9", "%ba", "%bb", "%bc", "%bd", "%be", "%bf",
110
    "%c0", "%c1", "%c2", "%c3", "%c4", "%c5", "%c6", "%c7",
111
    "%c8", "%c9", "%ca", "%cb", "%cc", "%cd", "%ce", "%cf",
112
    "%d0", "%d1", "%d2", "%d3", "%d4", "%d5", "%d6", "%d7",
113
    "%d8", "%d9", "%da", "%db", "%dc", "%dd", "%de", "%df",
114
    "%e0", "%e1", "%e2", "%e3", "%e4", "%e5", "%e6", "%e7",
115
    "%e8", "%e9", "%ea", "%eb", "%ec", "%ed", "%ee", "%ef",
116
    "%f0", "%f1", "%f2", "%f3", "%f4", "%f5", "%f6", "%f7",
117
    "%f8", "%f9", "%fa", "%fb", "%fc", "%fd", "%fe", "%ff"
118
    };
119

    
120
  private static String[][][] mCountry;
121
  private static String[][][] mName;
122
  private static float[][][] mTime;
123
  private static int[][] mPlaces;
124

    
125
  private static RubikNetwork mThis;
126
  private static String mScores = "";
127
  private static boolean mRunning = false;
128
  private static Updatee mUpdatee;
129
  private static String mVersion;
130
  private static int mNumObjects;
131
  private static RubikUpdates mUpdates;
132
  private static int mDebugState;
133

    
134
///////////////////////////////////////////////////////////////////////////////////////////////////
135

    
136
  private static void initializeStatics()
137
    {
138
    int newNum = RubikObjectList.getNumObjects();
139

    
140
    if( mCountry==null || newNum!=mNumObjects ) mCountry = new String[newNum][MAX_LEVEL][MAX_PLACES];
141
    if( mName==null    || newNum!=mNumObjects ) mName    = new String[newNum][MAX_LEVEL][MAX_PLACES];
142
    if( mTime==null    || newNum!=mNumObjects ) mTime    = new  float[newNum][MAX_LEVEL][MAX_PLACES];
143
    if( mPlaces==null  || newNum!=mNumObjects ) mPlaces  = new    int[newNum][MAX_LEVEL];
144

    
145
    if( mUpdates==null ) mUpdates = new RubikUpdates();
146

    
147
    mNumObjects = newNum;
148
    }
149

    
150
///////////////////////////////////////////////////////////////////////////////////////////////////
151

    
152
  private static String computeHash(String stringToHash, byte[] salt)
153
    {
154
    String generatedPassword;
155

    
156
    try
157
      {
158
      MessageDigest md = MessageDigest.getInstance("MD5");
159
      md.update(salt);
160
      byte[] bytes = md.digest(stringToHash.getBytes());
161
      StringBuilder sb = new StringBuilder();
162

    
163
      for (byte aByte : bytes)
164
        {
165
        sb.append(Integer.toString((aByte & 0xff) + 0x100, 16).substring(1));
166
        }
167

    
168
      generatedPassword = sb.toString();
169
      }
170
    catch (NoSuchAlgorithmException e)
171
      {
172
      return "NoSuchAlgorithm";
173
      }
174

    
175
    return generatedPassword;
176
    }
177

    
178
///////////////////////////////////////////////////////////////////////////////////////////////////
179

    
180
  private boolean fillValuesNormal(ScoresReceiver receiver)
181
    {
182
    int begin=-1 ,end, len = mScores.length();
183
    String row;
184

    
185
    if( len==0 )
186
      {
187
      receiver.error("1");
188
      return false;
189
      }
190
    else if( len<=2 )
191
      {
192
      receiver.error(mScores);
193
      return false;
194
      }
195

    
196
    for(int i=0; i<mNumObjects; i++)
197
      for(int j=0; j<MAX_LEVEL; j++)
198
        {
199
        mPlaces[i][j] = 0;
200
        }
201

    
202
    while( begin<len )
203
      {
204
      end = mScores.indexOf('\n', begin+1);
205
      if( end<0 ) end = len;
206

    
207
      try
208
        {
209
        row = mScores.substring(begin+1,end);
210
        fillRow(row);
211
        }
212
      catch(Exception ex)
213
        {
214
        // faulty row - ignore
215
        }
216

    
217
      begin = end;
218
      }
219

    
220
    return true;
221
    }
222

    
223
///////////////////////////////////////////////////////////////////////////////////////////////////
224

    
225
  private void fillRow(String row)
226
    {
227
    int s1 = row.indexOf(' ');
228
    int s2 = row.indexOf(' ',s1+1);
229
    int s3 = row.indexOf(' ',s2+1);
230
    int s4 = row.indexOf(' ',s3+1);
231
    int s5 = row.length();
232

    
233
    if( s5>s4 && s4>s3 && s3>s2 && s2>s1 && s1>0 )
234
      {
235
      int object = RubikObjectList.getOrdinal( row.substring(0,s1) );
236

    
237
      if( object>=0 && object<mNumObjects )
238
        {
239
        int level      = Integer.parseInt( row.substring(s1+1,s2) );
240
        String name    = row.substring(s2+1, s3);
241
        int time       = Integer.parseInt( row.substring(s3+1,s4) );
242
        String country = row.substring(s4+1, s5);
243

    
244
        if( country.equals("do") ) country = "dm"; // see RubikScores.setCountry()
245

    
246
        if(level>=0 && level<MAX_LEVEL)
247
          {
248
          int p = mPlaces[object][level];
249
          mPlaces[object][level]++;
250

    
251
          mCountry[object][level][p] = country;
252
          mName   [object][level][p] = name;
253
          mTime   [object][level][p] = ((float)(time/10))/100.0f;
254
          }
255
        }
256
      }
257
    else
258
      {
259
      tryDoCommand(row);
260
      }
261
    }
262

    
263
///////////////////////////////////////////////////////////////////////////////////////////////////
264

    
265
  private void tryDoCommand(String row)
266
    {
267
    if( row.startsWith("comm") )
268
      {
269
      int colon = row.indexOf(':');
270

    
271
      if( colon>0 )
272
        {
273
        String commandNumber = row.substring(4,colon);
274
        int number;
275

    
276
        try
277
          {
278
          number = Integer.parseInt(commandNumber);
279
          }
280
        catch(NumberFormatException ex)
281
          {
282
          number=0;
283
          }
284

    
285
        if(number==1)
286
          {
287
          String country = row.substring(colon+1);
288
          RubikScores scores = RubikScores.getInstance();
289
          scores.setCountry(country);
290
          }
291
        }
292
      }
293
    }
294

    
295
///////////////////////////////////////////////////////////////////////////////////////////////////
296

    
297
  private int getRendererType(String renderer)
298
    {
299
    if( renderer.contains("Adreno")  ) return REND_ADRENO;
300
    if( renderer.contains("Mali")    ) return REND_MALI;
301
    if( renderer.contains("PowerVR") ) return REND_POWER;
302

    
303
    return REND_OTHER;
304
    }
305

    
306
///////////////////////////////////////////////////////////////////////////////////////////////////
307

    
308
  private String parseRenderer(final int type, String renderer)
309
    {
310
    if( type==REND_ADRENO || type==REND_POWER )
311
      {
312
      int lastSpace = renderer.lastIndexOf(' ');
313
      String ret = renderer.substring(lastSpace+1);
314
      return URLencode(ret);
315
      }
316

    
317
    if( type==REND_MALI )
318
      {
319
      int firstHyphen = renderer.indexOf('-');
320
      String ret = renderer.substring(firstHyphen+1);
321
      return URLencode(ret);
322
      }
323

    
324
    return "other";
325
    }
326

    
327
///////////////////////////////////////////////////////////////////////////////////////////////////
328

    
329
  private String parseVersion(final int type, String version)
330
    {
331
    switch(type)
332
      {
333
      case REND_ADRENO: int aMonkey = version.indexOf('@');
334
                        int aDot = version.indexOf('.', aMonkey);
335
                        String ret1 = aDot>=3 ? version.substring(aDot-3,aDot) : "";
336
                        return URLencode(ret1);
337
      case REND_MALI  : int mV1 = version.indexOf("v1");
338
                        int mHyphen = version.indexOf('-', mV1);
339
                        String ret2 = mHyphen>mV1+3 && mV1>=0 ? version.substring(mV1+3,mHyphen) : "";
340
                        return URLencode(ret2);
341
      case REND_POWER : int pMonkey = version.indexOf('@');
342
                        int pSpace  = version.lastIndexOf(' ');
343
                        String ret3 = pSpace>=0 && pMonkey>pSpace+1 ? version.substring(pSpace+1,pMonkey) : "";
344
                        return URLencode(ret3);
345
      default         : return "";
346
      }
347
    }
348

    
349
///////////////////////////////////////////////////////////////////////////////////////////////////
350

    
351
  private String URLencode(String s)
352
    {
353
    StringBuilder sbuf = new StringBuilder();
354
    int len = s.length();
355

    
356
    for (int i = 0; i < len; i++)
357
      {
358
      int ch = s.charAt(i);
359

    
360
           if ('A' <= ch && ch <= 'Z') sbuf.append((char)ch);
361
      else if ('a' <= ch && ch <= 'z') sbuf.append((char)ch);
362
      else if ('0' <= ch && ch <= '9') sbuf.append((char)ch);
363
      else if (ch == ' '             ) sbuf.append('+');
364
      else if (ch == '-' || ch == '_'
365
            || ch == '.' || ch == '!'
366
            || ch == '~' || ch == '*'
367
            || ch == '\'' || ch == '('
368
            || ch == ')'             ) sbuf.append((char)ch);
369
      else if (ch <= 0x007f)           sbuf.append(hex[ch]);
370
      else if (ch <= 0x07FF)
371
        {
372
        sbuf.append(hex[0xc0 | (ch >> 6)]);
373
        sbuf.append(hex[0x80 | (ch & 0x3F)]);
374
        }
375
      else
376
        {
377
        sbuf.append(hex[0xe0 | (ch >> 12)]);
378
        sbuf.append(hex[0x80 | ((ch >> 6) & 0x3F)]);
379
        sbuf.append(hex[0x80 | (ch & 0x3F)]);
380
        }
381
      }
382

    
383
    return sbuf.toString();
384
    }
385

    
386
///////////////////////////////////////////////////////////////////////////////////////////////////
387

    
388
  private boolean network(String url, ScoresReceiver receiver)
389
    {
390
    try
391
      {
392
      java.net.URL connectURL = new URL(url);
393
      HttpURLConnection conn = (HttpURLConnection)connectURL.openConnection();
394

    
395
      conn.setDoInput(true);
396
      conn.setDoOutput(true);
397
      conn.setUseCaches(false);
398
      conn.setRequestMethod("GET");
399
      conn.connect();
400
      conn.getOutputStream().flush();
401

    
402
      InputStream is = conn.getInputStream();
403
      BufferedReader r = new BufferedReader(new InputStreamReader(is));
404
      StringBuilder total = new StringBuilder();
405

    
406
      for (String line; (line = r.readLine()) != null; )
407
        {
408
        total.append(line).append('\n');
409
        }
410

    
411
      mScores = total.toString();
412
      conn.disconnect();
413
      }
414
    catch( final UnknownHostException e )
415
      {
416
      receiver.message("No access to Internet");
417
      return false;
418
      }
419
    catch( final SecurityException e )
420
      {
421
      receiver.message("Application not authorized to connect to the Internet");
422
      return false;
423
      }
424
    catch( final Exception e )
425
      {
426
      receiver.message(e.getMessage());
427
      return false;
428
      }
429

    
430
    if( mScores.length()==0 )
431
      {
432
      receiver.message("Failed to download scores");
433
      return false;
434
      }
435

    
436
    return true;
437
    }
438

    
439
///////////////////////////////////////////////////////////////////////////////////////////////////
440

    
441
  private String constructSuspiciousURL(String suspURL)
442
    {
443
    RubikScores scores = RubikScores.getInstance();
444
    int deviceID= scores.getDeviceID();
445
    String suspicious = URLencode(suspURL);
446

    
447
    String url="https://distorted.org/magic/cgi-bin/suspicious.cgi";
448
    url += "?i="+deviceID+"&d="+suspicious;
449

    
450
    return url;
451
    }
452

    
453
///////////////////////////////////////////////////////////////////////////////////////////////////
454

    
455
  private String constructDebugURL()
456
    {
457
    RubikScores scores = RubikScores.getInstance();
458
    String name = URLencode(scores.getName());
459
    int numRuns = scores.getNumRuns();
460
    int numPlay = scores.getNumPlays();
461
    String country = scores.getCountry();
462
    String renderer = DistortedLibrary.getDriverRenderer();
463
    String version  = DistortedLibrary.getDriverVersion();
464
    int objectAPI   = JsonWriter.VERSION_OBJECT_MAJOR;
465
    int tutorialAPI = JsonWriter.VERSION_EXTRAS_MAJOR;
466

    
467
    renderer = URLencode(renderer);
468
    version  = URLencode(version);
469

    
470
    String url="https://distorted.org/magic/cgi-bin/debugs.cgi";
471
    url += "?n="+name+"&r="+numRuns+"&p="+numPlay+"&c="+country+"&e="+mVersion+"d";
472
    url += "&d="+renderer+"&v="+version+"&a="+objectAPI+"&b="+tutorialAPI;
473

    
474
    return url;
475
    }
476

    
477
///////////////////////////////////////////////////////////////////////////////////////////////////
478

    
479
  private String constructDownloadURL()
480
    {
481
    RubikScores scores = RubikScores.getInstance();
482
    String name = URLencode(scores.getName());
483
    int numRuns = scores.getNumRuns();
484
    int numPlay = scores.getNumPlays();
485
    String country = scores.getCountry();
486

    
487
    String url="https://distorted.org/magic/cgi-bin/download.cgi";
488
    url += "?n="+name+"&r="+numRuns+"&p="+numPlay+"&c="+country+"&e="+mVersion;
489

    
490
    return url;
491
    }
492

    
493
///////////////////////////////////////////////////////////////////////////////////////////////////
494

    
495
  private String constructSubmitURL()
496
    {
497
    RubikScores scores = RubikScores.getInstance();
498
    String name = URLencode(scores.getName());
499
    String veri = scores.isVerified() ? "1" : "";
500
    int numRuns = scores.getNumRuns();
501
    int numPlay = scores.getNumPlays();
502
    int deviceID= scores.getDeviceID();
503
    String reclist = scores.getRecordList("&o=","&l=","&t=");
504
    String country = scores.getCountry();
505
    long epoch = System.currentTimeMillis();
506
    String salt = "cuboid";
507

    
508
    String renderer = DistortedLibrary.getDriverRenderer();
509
    String version  = DistortedLibrary.getDriverVersion();
510

    
511
    int type = getRendererType(renderer);
512
    renderer = parseRenderer(type,renderer);
513
    version  = parseVersion(type,version);
514

    
515
    String url1="https://distorted.org/magic/cgi-bin/submit.cgi";
516
    String url2 = "n="+name+"&v="+veri+"&r="+numRuns+"&p="+numPlay+"&i="+deviceID+"&e="+mVersion;
517
    url2 += "&d="+renderer+"&s="+version+reclist+"&c="+country+"&f="+epoch;
518
    String hash = computeHash( url2, salt.getBytes() );
519

    
520
    return url1 + "?" + url2 + "&h=" + hash;
521
    }
522

    
523
///////////////////////////////////////////////////////////////////////////////////////////////////
524

    
525
  private boolean gottaDownload()
526
    {
527
    return ((mScores.length()==0) && !mRunning);
528
    }
529

    
530
///////////////////////////////////////////////////////////////////////////////////////////////////
531

    
532
  private void figureOutVersion(FragmentActivity act)
533
    {
534
    try
535
      {
536
      PackageInfo pInfo = act.getPackageManager().getPackageInfo( act.getPackageName(), 0);
537
      mVersion = pInfo.versionName;
538
      }
539
    catch (PackageManager.NameNotFoundException e)
540
      {
541
      mVersion = "0.9.2";
542
      }
543
    }
544

    
545
///////////////////////////////////////////////////////////////////////////////////////////////////
546

    
547
  private void downloadThread(ScoresReceiver receiver)
548
    {
549
    try
550
      {
551
      if( gottaDownload() )
552
        {
553
        mRunning = true;
554
        boolean receiveValues = network(constructDownloadURL(),receiver);
555

    
556
        if( mRunning )
557
          {
558
          receiveValues = fillValuesNormal(receiver);
559
          mRunning = false;
560
          }
561

    
562
        if( receiveValues ) receiver.receive(mCountry, mName, mTime);
563
        }
564
      }
565
    catch( Exception e )
566
      {
567
      receiver.message("Exception downloading records: "+e.getMessage() );
568
      }
569
    }
570

    
571
///////////////////////////////////////////////////////////////////////////////////////////////////
572

    
573
  private void submitThread(ScoresReceiver receiver)
574
    {
575
    try
576
      {
577
      mRunning = true;
578
      RubikScores scores = RubikScores.getInstance();
579

    
580
      if( scores.thereAreUnsubmittedRecords() )
581
        {
582
        boolean receiveValues = network(constructSubmitURL(),receiver);
583

    
584
        if( mRunning )
585
          {
586
          receiveValues = fillValuesNormal(receiver);
587
          mRunning = false;
588
          }
589

    
590
        if( receiveValues )
591
          {
592
          RubikScores.getInstance().successfulSubmit();
593
          receiver.receive(mCountry, mName, mTime);
594
          }
595
        }
596
      }
597
    catch( Exception e )
598
      {
599
      receiver.message("Exception submitting records: "+e.getMessage() );
600
      }
601
    }
602

    
603
///////////////////////////////////////////////////////////////////////////////////////////////////
604

    
605
  private void debugThread()
606
    {
607
    String url = constructDebugURL();
608
/*
609
    try { Thread.sleep(5000); }
610
    catch( InterruptedException ignored) {}
611
*/
612
    try
613
      {
614
      java.net.URL connectURL = new URL(url);
615
      HttpURLConnection conn = (HttpURLConnection)connectURL.openConnection();
616

    
617
      conn.setDoInput(true);
618
      conn.setDoOutput(true);
619
      conn.setUseCaches(false);
620
      conn.setRequestMethod("GET");
621
      conn.connect();
622
      conn.getOutputStream().flush();
623

    
624
      InputStream is = conn.getInputStream();
625
      BufferedReader r = new BufferedReader(new InputStreamReader(is));
626
      StringBuilder answer = new StringBuilder();
627

    
628
      for (String line; (line = r.readLine()) != null; )
629
        {
630
        answer.append(line).append('\n');
631
        }
632

    
633
      String updates = answer.toString();
634
      conn.disconnect();
635
      mUpdates.parse(updates);
636

    
637
      if( mUpdatee!=null ) mUpdatee.receiveUpdate(mUpdates);
638
      mDebugState = DEBUG_SUCCESS;
639
      }
640
    catch( final Exception e )
641
      {
642
      if( mUpdatee!=null ) mUpdatee.errorUpdate();
643
      mDebugState = DEBUG_FAILURE;
644
      }
645
    }
646

    
647
///////////////////////////////////////////////////////////////////////////////////////////////////
648

    
649
  private void suspiciousThread(String suspURL)
650
    {
651
    String url = constructSuspiciousURL(suspURL);
652

    
653
    try
654
      {
655
      java.net.URL connectURL = new URL(url);
656
      HttpURLConnection conn = (HttpURLConnection)connectURL.openConnection();
657

    
658
      conn.setDoInput(true);
659
      conn.setDoOutput(true);
660
      conn.setUseCaches(false);
661
      conn.setRequestMethod("GET");
662
      conn.connect();
663
      conn.getOutputStream().flush();
664
      conn.getInputStream();
665
      conn.disconnect();
666
      }
667
    catch( final Exception e )
668
      {
669
      // ignore
670
      }
671
    }
672

    
673
///////////////////////////////////////////////////////////////////////////////////////////////////
674

    
675
  private Bitmap downloadIcon(String url)
676
    {
677
    try
678
      {
679
      java.net.URL connectURL = new URL(url);
680
      HttpURLConnection conn = (HttpURLConnection) connectURL.openConnection();
681
      conn.setDoInput(true);
682
      conn.connect();
683
      InputStream input = conn.getInputStream();
684
      Bitmap icon = BitmapFactory.decodeStream(input);
685
      conn.disconnect();
686
      return icon;
687
      }
688
    catch (IOException e)
689
      {
690
      android.util.Log.e("D", "Failed to download "+url);
691
      android.util.Log.e("D", e.getMessage() );
692
      return null;
693
      }
694
    }
695

    
696
///////////////////////////////////////////////////////////////////////////////////////////////////
697

    
698
  private void iconThread(Context context, IconReceiver receiver)
699
    {
700
    int numC = mUpdates.getCompletedNumber();
701
    int numS = mUpdates.getStartedNumber();
702

    
703
    for(int c=0; c<numC; c++)
704
      {
705
      int iconPresent = mUpdates.getCompletedIconPresent(c);
706

    
707
      if( iconPresent!=0 )
708
        {
709
        boolean downloaded = false;
710
        Bitmap icon = mUpdates.getCompletedIcon(context,c);
711

    
712
        if( icon==null )
713
          {
714
          String url = mUpdates.getCompletedURL(c);
715
          icon = downloadIcon(url);
716
          downloaded = true;
717

    
718
          if( SHOW_DOWNLOADED_DEBUG ) android.util.Log.e("D", "Downloading icon "+url);
719
          }
720
        if( icon!=null )
721
          {
722
          mUpdates.setCompletedIcon(c,icon);
723
          receiver.iconDownloaded(c,icon,downloaded);
724
          }
725
        }
726
      }
727

    
728
    for(int s=0; s<numS; s++)
729
      {
730
      int iconPresent = mUpdates.getStartedIconPresent(s);
731

    
732
      if( iconPresent!=0 )
733
        {
734
        boolean downloaded = false;
735
        Bitmap icon = mUpdates.getStartedIcon(context,s);
736

    
737
        if( icon==null )
738
          {
739
          String url = mUpdates.getStartedURL(s);
740
          icon = downloadIcon(url);
741
          downloaded = true;
742

    
743
          if( SHOW_DOWNLOADED_DEBUG ) android.util.Log.e("D", "Downloading icon "+url);
744
          }
745
        if( icon!=null )
746
          {
747
          mUpdates.setStartedIcon(s,icon);
748
          receiver.iconDownloaded(numC+s,icon,downloaded);
749
          }
750
        }
751
      }
752
    }
753

    
754
///////////////////////////////////////////////////////////////////////////////////////////////////
755

    
756
  private InputStream downloadJSON(String name)
757
    {
758
    String url = mUpdates.getURL() + name;
759

    
760
    try
761
      {
762
      if( SHOW_DOWNLOADED_DEBUG ) android.util.Log.e("D", "Downloading JSON "+url);
763

    
764
      java.net.URL connectURL = new URL(url);
765
      HttpURLConnection conn = (HttpURLConnection) connectURL.openConnection();
766
      conn.setDoInput(true);
767
      conn.connect();
768
      return conn.getInputStream();
769
      }
770
    catch (IOException e)
771
      {
772
      android.util.Log.e("D", "Failed to download "+url);
773
      android.util.Log.e("D", e.getMessage() );
774
      return null;
775
      }
776
    }
777

    
778
///////////////////////////////////////////////////////////////////////////////////////////////////
779

    
780
  private void jsonThread(final RubikUpdates.UpdateInfo info, Downloadee downloadee)
781
    {
782
    if(info.mUpdateObject) info.mObjectStream = downloadJSON(info.mObjectShortName+"_object.json");
783
    if(info.mUpdateExtras) info.mExtrasStream = downloadJSON(info.mObjectShortName+"_extras.json");
784

    
785
    downloadee.jsonDownloaded();
786

    
787
    try
788
      {
789
      if( info.mObjectStream!=null ) info.mObjectStream.close();
790
      }
791
    catch(IOException ioe)
792
      {
793
      android.util.Log.e("D", "failed to close object input stream");
794
      }
795

    
796
    try
797
      {
798
      if( info.mExtrasStream!=null ) info.mExtrasStream.close();
799
      }
800
    catch(IOException ioe)
801
      {
802
      android.util.Log.e("D", "failed to close extras input stream");
803
      }
804
    }
805

    
806
///////////////////////////////////////////////////////////////////////////////////////////////////
807

    
808
  private RubikNetwork()
809
    {
810

    
811
    }
812

    
813
///////////////////////////////////////////////////////////////////////////////////////////////////
814
// PUBLIC API
815
///////////////////////////////////////////////////////////////////////////////////////////////////
816

    
817
  public static void onPause()
818
    {
819
    mRunning = false;
820
    }
821

    
822
///////////////////////////////////////////////////////////////////////////////////////////////////
823

    
824
  public static RubikNetwork getInstance()
825
    {
826
    if( mThis==null ) mThis = new RubikNetwork();
827
    return mThis;
828
    }
829

    
830
///////////////////////////////////////////////////////////////////////////////////////////////////
831

    
832
  public void download(final ScoresReceiver receiver, final FragmentActivity act)
833
    {
834
    initializeStatics();
835
    figureOutVersion(act);
836

    
837
    Thread thread = new Thread()
838
      {
839
      public void run()
840
        {
841
        downloadThread(receiver);
842
        }
843
      };
844

    
845
    thread.start();
846
    }
847

    
848
///////////////////////////////////////////////////////////////////////////////////////////////////
849

    
850
  public void submit(ScoresReceiver receiver, final FragmentActivity act)
851
    {
852
    initializeStatics();
853
    figureOutVersion(act);
854

    
855
    Thread thread = new Thread()
856
      {
857
      public void run()
858
        {
859
        submitThread(receiver);
860
        }
861
      };
862

    
863
    thread.start();
864
    }
865

    
866
///////////////////////////////////////////////////////////////////////////////////////////////////
867

    
868
  public void debug()
869
    {
870
    initializeStatics();
871
    mDebugState = DEBUG_RUNNING;
872

    
873
    Thread thread = new Thread()
874
      {
875
      public void run()
876
        {
877
        debugThread();
878
        }
879
      };
880

    
881
    thread.start();
882
    }
883

    
884
///////////////////////////////////////////////////////////////////////////////////////////////////
885

    
886
  public void suspicious(final String suspicious)
887
    {
888
    initializeStatics();
889

    
890
    Thread thread = new Thread()
891
      {
892
      public void run()
893
        {
894
        suspiciousThread(suspicious);
895
        }
896
      };
897

    
898
    thread.start();
899
    }
900

    
901
///////////////////////////////////////////////////////////////////////////////////////////////////
902
// Yes it can happen that the second Updatee registers before we sent an update to the first one
903
// and, as a result, the update never gets sent to the first one. This is not a problem (now, when
904
// there are only two updatees - the RubikStatePlay and the UpdateDialog)
905
//
906
// Yes, there is also a remote possibility that the two threads executing this function and executing
907
// the sendDebug() get swapped exactly in unlucky moment and the update never gets to the updatee.
908
// We don't care about such remote possibility, then the app simply would signal that there are no
909
// updates available.
910

    
911
  public void signUpForUpdates(Updatee updatee)
912
    {
913
         if( mDebugState==DEBUG_SUCCESS ) updatee.receiveUpdate(mUpdates);
914
    else if( mDebugState==DEBUG_FAILURE ) updatee.errorUpdate();
915
    else mUpdatee = updatee;
916
    }
917

    
918
///////////////////////////////////////////////////////////////////////////////////////////////////
919

    
920
  public void downloadIcons(final Context context, final IconReceiver receiver)
921
    {
922
    initializeStatics();
923

    
924
    Thread thread = new Thread()
925
      {
926
      public void run()
927
        {
928
        iconThread(context,receiver);
929
        }
930
      };
931

    
932
    thread.start();
933
    }
934

    
935
///////////////////////////////////////////////////////////////////////////////////////////////////
936

    
937
  public void downloadJSON(final RubikUpdates.UpdateInfo info, final Downloadee downloadee)
938
    {
939
    initializeStatics();
940

    
941
    Thread thread = new Thread()
942
      {
943
      public void run()
944
        {
945
        jsonThread(info,downloadee);
946
        }
947
      };
948

    
949
    thread.start();
950
    }
951

    
952
///////////////////////////////////////////////////////////////////////////////////////////////////
953

    
954
  public void updateDone(String shortName)
955
    {
956
    mUpdates.updateDone(shortName);
957
    }
958
}
(2-2/4)