Project

General

Profile

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

magiccube / src / main / java / org / distorted / external / RubikNetwork.java @ 84d746d7

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

    
46
///////////////////////////////////////////////////////////////////////////////////////////////////
47

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

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

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

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

    
73
  public static final int MAX_PLACES = 10;
74

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

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

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

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

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

    
133
///////////////////////////////////////////////////////////////////////////////////////////////////
134

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

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

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

    
146
    mNumObjects = newNum;
147
    }
148

    
149
///////////////////////////////////////////////////////////////////////////////////////////////////
150

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

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

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

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

    
174
    return generatedPassword;
175
    }
176

    
177
///////////////////////////////////////////////////////////////////////////////////////////////////
178

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

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

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

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

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

    
216
      begin = end;
217
      }
218

    
219
    return true;
220
    }
221

    
222
///////////////////////////////////////////////////////////////////////////////////////////////////
223

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

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

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

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

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

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

    
262
///////////////////////////////////////////////////////////////////////////////////////////////////
263

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

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

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

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

    
294
///////////////////////////////////////////////////////////////////////////////////////////////////
295

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

    
302
    return REND_OTHER;
303
    }
304

    
305
///////////////////////////////////////////////////////////////////////////////////////////////////
306

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

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

    
323
    return "other";
324
    }
325

    
326
///////////////////////////////////////////////////////////////////////////////////////////////////
327

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

    
348
///////////////////////////////////////////////////////////////////////////////////////////////////
349

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

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

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

    
382
    return sbuf.toString();
383
    }
384

    
385
///////////////////////////////////////////////////////////////////////////////////////////////////
386

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

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

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

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

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

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

    
435
    return true;
436
    }
437

    
438
///////////////////////////////////////////////////////////////////////////////////////////////////
439

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

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

    
449
    return url;
450
    }
451

    
452
///////////////////////////////////////////////////////////////////////////////////////////////////
453

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

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

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

    
473
    return url;
474
    }
475

    
476
///////////////////////////////////////////////////////////////////////////////////////////////////
477

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

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

    
489
    return url;
490
    }
491

    
492
///////////////////////////////////////////////////////////////////////////////////////////////////
493

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

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

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

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

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

    
522
///////////////////////////////////////////////////////////////////////////////////////////////////
523

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

    
529
///////////////////////////////////////////////////////////////////////////////////////////////////
530

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

    
544
///////////////////////////////////////////////////////////////////////////////////////////////////
545

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

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

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

    
570
///////////////////////////////////////////////////////////////////////////////////////////////////
571

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

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

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

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

    
602
///////////////////////////////////////////////////////////////////////////////////////////////////
603

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

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

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

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

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

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

    
646
///////////////////////////////////////////////////////////////////////////////////////////////////
647

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

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

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

    
672
///////////////////////////////////////////////////////////////////////////////////////////////////
673

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

    
695
///////////////////////////////////////////////////////////////////////////////////////////////////
696

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

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

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

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

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

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

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

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

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

    
753
///////////////////////////////////////////////////////////////////////////////////////////////////
754

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

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

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

    
777
///////////////////////////////////////////////////////////////////////////////////////////////////
778

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

    
784
    downloadee.jsonDownloaded();
785

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

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

    
805
///////////////////////////////////////////////////////////////////////////////////////////////////
806

    
807
  private RubikNetwork()
808
    {
809

    
810
    }
811

    
812
///////////////////////////////////////////////////////////////////////////////////////////////////
813
// PUBLIC API
814
///////////////////////////////////////////////////////////////////////////////////////////////////
815

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

    
821
///////////////////////////////////////////////////////////////////////////////////////////////////
822

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

    
829
///////////////////////////////////////////////////////////////////////////////////////////////////
830

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

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

    
844
    thread.start();
845
    }
846

    
847
///////////////////////////////////////////////////////////////////////////////////////////////////
848

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

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

    
862
    thread.start();
863
    }
864

    
865
///////////////////////////////////////////////////////////////////////////////////////////////////
866

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

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

    
880
    thread.start();
881
    }
882

    
883
///////////////////////////////////////////////////////////////////////////////////////////////////
884

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

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

    
897
    thread.start();
898
    }
899

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

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

    
917
///////////////////////////////////////////////////////////////////////////////////////////////////
918

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

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

    
931
    thread.start();
932
    }
933

    
934
///////////////////////////////////////////////////////////////////////////////////////////////////
935

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

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

    
948
    thread.start();
949
    }
950

    
951
///////////////////////////////////////////////////////////////////////////////////////////////////
952

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