001/*
002 * Licensed to the Apache Software Foundation (ASF) under one or more
003 * contributor license agreements.  See the NOTICE file distributed with
004 * this work for additional information regarding copyright ownership.
005 * The ASF licenses this file to You under the Apache License, Version 2.0
006 * (the "License"); you may not use this file except in compliance with
007 * the License.  You may obtain a copy of the License at
008 *
009 *      http://www.apache.org/licenses/LICENSE-2.0
010 *
011 * Unless required by applicable law or agreed to in writing, software
012 * distributed under the License is distributed on an "AS IS" BASIS,
013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
014 * See the License for the specific language governing permissions and
015 * limitations under the License.
016 */
017package org.apache.juneau.msgpack;
018
019import java.lang.annotation.*;
020import java.util.*;
021import java.util.concurrent.*;
022
023import org.apache.juneau.*;
024import org.apache.juneau.internal.*;
025import org.apache.juneau.parser.*;
026import org.apache.juneau.utils.*;
027
028/**
029 * Parses a MessagePack stream into a POJO model.
030 *
031 * <h5 class='topic'>Media types</h5>
032 *
033 * Handles <c>Content-Type</c> types:  <bc>octal/msgpack</bc>
034 *
035 * <h5 class='section'>Notes:</h5><ul>
036 *    <li class='note'>This class is thread safe and reusable.
037 * </ul>
038 *
039 * <h5 class='section'>See Also:</h5><ul>
040 *    <li class='link'><a class="doclink" href="https://juneau.apache.org/docs/topics/MessagePackBasics">MessagePack Basics</a>
041
042 * </ul>
043 */
044public class MsgPackParser extends InputStreamParser implements MsgPackMetaProvider {
045
046   //-------------------------------------------------------------------------------------------------------------------
047   // Static
048   //-------------------------------------------------------------------------------------------------------------------
049
050   /** Default parser, all default settings.*/
051   public static final MsgPackParser DEFAULT = new MsgPackParser(create());
052
053   /** Default parser, all default settings, string input encoded as spaced-hex.*/
054   public static final MsgPackParser DEFAULT_SPACED_HEX = new SpacedHex(create());
055
056   /** Default parser, all default settings, string input encoded as BASE64.*/
057   public static final MsgPackParser DEFAULT_BASE64 = new Base64(create());
058
059   /**
060    * Creates a new builder for this object.
061    *
062    * @return A new builder.
063    */
064   public static Builder create() {
065      return new Builder();
066   }
067
068   //-------------------------------------------------------------------------------------------------------------------
069   // Static subclasses
070   //-------------------------------------------------------------------------------------------------------------------
071
072   /** Default parser, string input encoded as spaced-hex. */
073   public static class SpacedHex extends MsgPackParser {
074
075      /**
076       * Constructor.
077       *
078       * @param builder The builder for this object.
079       */
080      public SpacedHex(Builder builder) {
081         super(
082            builder.binaryFormat(BinaryFormat.SPACED_HEX)
083         );
084      }
085   }
086
087   /** Default parser, string input encoded as BASE64. */
088   public static class Base64 extends MsgPackParser {
089
090      /**
091       * Constructor.
092       *
093       * @param builder The builder for this object.
094       */
095      public Base64(Builder builder) {
096         super(
097            builder.binaryFormat(BinaryFormat.BASE64)
098         );
099      }
100   }
101
102   //-------------------------------------------------------------------------------------------------------------------
103   // Builder
104   //-------------------------------------------------------------------------------------------------------------------
105
106   /**
107    * Builder class.
108    */
109   public static class Builder extends InputStreamParser.Builder {
110
111      private static final Cache<HashKey,MsgPackParser> CACHE = Cache.of(HashKey.class, MsgPackParser.class).build();
112
113      /**
114       * Constructor, default settings.
115       */
116      protected Builder() {
117         consumes("octal/msgpack");
118      }
119
120      /**
121       * Copy constructor.
122       *
123       * @param copyFrom The bean to copy from.
124       */
125      protected Builder(MsgPackParser copyFrom) {
126         super(copyFrom);
127      }
128
129      /**
130       * Copy constructor.
131       *
132       * @param copyFrom The builder to copy from.
133       */
134      protected Builder(Builder copyFrom) {
135         super(copyFrom);
136      }
137
138      @Override /* Context.Builder */
139      public Builder copy() {
140         return new Builder(this);
141      }
142
143      @Override /* Context.Builder */
144      public MsgPackParser build() {
145         return cache(CACHE).build(MsgPackParser.class);
146      }
147
148      @Override /* Context.Builder */
149      public HashKey hashKey() {
150         return super.hashKey();
151      }
152      //-----------------------------------------------------------------------------------------------------------------
153      // Properties
154      //-----------------------------------------------------------------------------------------------------------------
155      @Override /* Overridden from Builder */
156      public Builder annotations(Annotation...values) {
157         super.annotations(values);
158         return this;
159      }
160
161      @Override /* Overridden from Builder */
162      public Builder apply(AnnotationWorkList work) {
163         super.apply(work);
164         return this;
165      }
166
167      @Override /* Overridden from Builder */
168      public Builder applyAnnotations(Object...from) {
169         super.applyAnnotations(from);
170         return this;
171      }
172
173      @Override /* Overridden from Builder */
174      public Builder applyAnnotations(Class<?>...from) {
175         super.applyAnnotations(from);
176         return this;
177      }
178
179      @Override /* Overridden from Builder */
180      public Builder cache(Cache<HashKey,? extends org.apache.juneau.Context> value) {
181         super.cache(value);
182         return this;
183      }
184
185      @Override /* Overridden from Builder */
186      public Builder debug() {
187         super.debug();
188         return this;
189      }
190
191      @Override /* Overridden from Builder */
192      public Builder debug(boolean value) {
193         super.debug(value);
194         return this;
195      }
196
197      @Override /* Overridden from Builder */
198      public Builder impl(Context value) {
199         super.impl(value);
200         return this;
201      }
202
203      @Override /* Overridden from Builder */
204      public Builder type(Class<? extends org.apache.juneau.Context> value) {
205         super.type(value);
206         return this;
207      }
208
209      @Override /* Overridden from Builder */
210      public Builder beanClassVisibility(Visibility value) {
211         super.beanClassVisibility(value);
212         return this;
213      }
214
215      @Override /* Overridden from Builder */
216      public Builder beanConstructorVisibility(Visibility value) {
217         super.beanConstructorVisibility(value);
218         return this;
219      }
220
221      @Override /* Overridden from Builder */
222      public Builder beanContext(BeanContext value) {
223         super.beanContext(value);
224         return this;
225      }
226
227      @Override /* Overridden from Builder */
228      public Builder beanContext(BeanContext.Builder value) {
229         super.beanContext(value);
230         return this;
231      }
232
233      @Override /* Overridden from Builder */
234      public Builder beanDictionary(java.lang.Class<?>...values) {
235         super.beanDictionary(values);
236         return this;
237      }
238
239      @Override /* Overridden from Builder */
240      public Builder beanFieldVisibility(Visibility value) {
241         super.beanFieldVisibility(value);
242         return this;
243      }
244
245      @Override /* Overridden from Builder */
246      public Builder beanInterceptor(Class<?> on, Class<? extends org.apache.juneau.swap.BeanInterceptor<?>> value) {
247         super.beanInterceptor(on, value);
248         return this;
249      }
250
251      @Override /* Overridden from Builder */
252      public Builder beanMapPutReturnsOldValue() {
253         super.beanMapPutReturnsOldValue();
254         return this;
255      }
256
257      @Override /* Overridden from Builder */
258      public Builder beanMethodVisibility(Visibility value) {
259         super.beanMethodVisibility(value);
260         return this;
261      }
262
263      @Override /* Overridden from Builder */
264      public Builder beanProperties(Map<String,Object> values) {
265         super.beanProperties(values);
266         return this;
267      }
268
269      @Override /* Overridden from Builder */
270      public Builder beanProperties(Class<?> beanClass, String properties) {
271         super.beanProperties(beanClass, properties);
272         return this;
273      }
274
275      @Override /* Overridden from Builder */
276      public Builder beanProperties(String beanClassName, String properties) {
277         super.beanProperties(beanClassName, properties);
278         return this;
279      }
280
281      @Override /* Overridden from Builder */
282      public Builder beanPropertiesExcludes(Map<String,Object> values) {
283         super.beanPropertiesExcludes(values);
284         return this;
285      }
286
287      @Override /* Overridden from Builder */
288      public Builder beanPropertiesExcludes(Class<?> beanClass, String properties) {
289         super.beanPropertiesExcludes(beanClass, properties);
290         return this;
291      }
292
293      @Override /* Overridden from Builder */
294      public Builder beanPropertiesExcludes(String beanClassName, String properties) {
295         super.beanPropertiesExcludes(beanClassName, properties);
296         return this;
297      }
298
299      @Override /* Overridden from Builder */
300      public Builder beanPropertiesReadOnly(Map<String,Object> values) {
301         super.beanPropertiesReadOnly(values);
302         return this;
303      }
304
305      @Override /* Overridden from Builder */
306      public Builder beanPropertiesReadOnly(Class<?> beanClass, String properties) {
307         super.beanPropertiesReadOnly(beanClass, properties);
308         return this;
309      }
310
311      @Override /* Overridden from Builder */
312      public Builder beanPropertiesReadOnly(String beanClassName, String properties) {
313         super.beanPropertiesReadOnly(beanClassName, properties);
314         return this;
315      }
316
317      @Override /* Overridden from Builder */
318      public Builder beanPropertiesWriteOnly(Map<String,Object> values) {
319         super.beanPropertiesWriteOnly(values);
320         return this;
321      }
322
323      @Override /* Overridden from Builder */
324      public Builder beanPropertiesWriteOnly(Class<?> beanClass, String properties) {
325         super.beanPropertiesWriteOnly(beanClass, properties);
326         return this;
327      }
328
329      @Override /* Overridden from Builder */
330      public Builder beanPropertiesWriteOnly(String beanClassName, String properties) {
331         super.beanPropertiesWriteOnly(beanClassName, properties);
332         return this;
333      }
334
335      @Override /* Overridden from Builder */
336      public Builder beansRequireDefaultConstructor() {
337         super.beansRequireDefaultConstructor();
338         return this;
339      }
340
341      @Override /* Overridden from Builder */
342      public Builder beansRequireSerializable() {
343         super.beansRequireSerializable();
344         return this;
345      }
346
347      @Override /* Overridden from Builder */
348      public Builder beansRequireSettersForGetters() {
349         super.beansRequireSettersForGetters();
350         return this;
351      }
352
353      @Override /* Overridden from Builder */
354      public Builder dictionaryOn(Class<?> on, java.lang.Class<?>...values) {
355         super.dictionaryOn(on, values);
356         return this;
357      }
358
359      @Override /* Overridden from Builder */
360      public Builder disableBeansRequireSomeProperties() {
361         super.disableBeansRequireSomeProperties();
362         return this;
363      }
364
365      @Override /* Overridden from Builder */
366      public Builder disableIgnoreMissingSetters() {
367         super.disableIgnoreMissingSetters();
368         return this;
369      }
370
371      @Override /* Overridden from Builder */
372      public Builder disableIgnoreTransientFields() {
373         super.disableIgnoreTransientFields();
374         return this;
375      }
376
377      @Override /* Overridden from Builder */
378      public Builder disableIgnoreUnknownNullBeanProperties() {
379         super.disableIgnoreUnknownNullBeanProperties();
380         return this;
381      }
382
383      @Override /* Overridden from Builder */
384      public Builder disableInterfaceProxies() {
385         super.disableInterfaceProxies();
386         return this;
387      }
388
389      @Override /* Overridden from Builder */
390      public <T> Builder example(Class<T> pojoClass, T o) {
391         super.example(pojoClass, o);
392         return this;
393      }
394
395      @Override /* Overridden from Builder */
396      public <T> Builder example(Class<T> pojoClass, String json) {
397         super.example(pojoClass, json);
398         return this;
399      }
400
401      @Override /* Overridden from Builder */
402      public Builder findFluentSetters() {
403         super.findFluentSetters();
404         return this;
405      }
406
407      @Override /* Overridden from Builder */
408      public Builder findFluentSetters(Class<?> on) {
409         super.findFluentSetters(on);
410         return this;
411      }
412
413      @Override /* Overridden from Builder */
414      public Builder ignoreInvocationExceptionsOnGetters() {
415         super.ignoreInvocationExceptionsOnGetters();
416         return this;
417      }
418
419      @Override /* Overridden from Builder */
420      public Builder ignoreInvocationExceptionsOnSetters() {
421         super.ignoreInvocationExceptionsOnSetters();
422         return this;
423      }
424
425      @Override /* Overridden from Builder */
426      public Builder ignoreUnknownBeanProperties() {
427         super.ignoreUnknownBeanProperties();
428         return this;
429      }
430
431      @Override /* Overridden from Builder */
432      public Builder ignoreUnknownEnumValues() {
433         super.ignoreUnknownEnumValues();
434         return this;
435      }
436
437      @Override /* Overridden from Builder */
438      public Builder implClass(Class<?> interfaceClass, Class<?> implClass) {
439         super.implClass(interfaceClass, implClass);
440         return this;
441      }
442
443      @Override /* Overridden from Builder */
444      public Builder implClasses(Map<Class<?>,Class<?>> values) {
445         super.implClasses(values);
446         return this;
447      }
448
449      @Override /* Overridden from Builder */
450      public Builder interfaceClass(Class<?> on, Class<?> value) {
451         super.interfaceClass(on, value);
452         return this;
453      }
454
455      @Override /* Overridden from Builder */
456      public Builder interfaces(java.lang.Class<?>...value) {
457         super.interfaces(value);
458         return this;
459      }
460
461      @Override /* Overridden from Builder */
462      public Builder locale(Locale value) {
463         super.locale(value);
464         return this;
465      }
466
467      @Override /* Overridden from Builder */
468      public Builder mediaType(MediaType value) {
469         super.mediaType(value);
470         return this;
471      }
472
473      @Override /* Overridden from Builder */
474      public Builder notBeanClasses(java.lang.Class<?>...values) {
475         super.notBeanClasses(values);
476         return this;
477      }
478
479      @Override /* Overridden from Builder */
480      public Builder notBeanPackages(String...values) {
481         super.notBeanPackages(values);
482         return this;
483      }
484
485      @Override /* Overridden from Builder */
486      public Builder propertyNamer(Class<? extends org.apache.juneau.PropertyNamer> value) {
487         super.propertyNamer(value);
488         return this;
489      }
490
491      @Override /* Overridden from Builder */
492      public Builder propertyNamer(Class<?> on, Class<? extends org.apache.juneau.PropertyNamer> value) {
493         super.propertyNamer(on, value);
494         return this;
495      }
496
497      @Override /* Overridden from Builder */
498      public Builder sortProperties() {
499         super.sortProperties();
500         return this;
501      }
502
503      @Override /* Overridden from Builder */
504      public Builder sortProperties(java.lang.Class<?>...on) {
505         super.sortProperties(on);
506         return this;
507      }
508
509      @Override /* Overridden from Builder */
510      public Builder stopClass(Class<?> on, Class<?> value) {
511         super.stopClass(on, value);
512         return this;
513      }
514
515      @Override /* Overridden from Builder */
516      public <T, S> Builder swap(Class<T> normalClass, Class<S> swappedClass, ThrowingFunction<T,S> swapFunction) {
517         super.swap(normalClass, swappedClass, swapFunction);
518         return this;
519      }
520
521      @Override /* Overridden from Builder */
522      public <T, S> Builder swap(Class<T> normalClass, Class<S> swappedClass, ThrowingFunction<T,S> swapFunction, ThrowingFunction<S,T> unswapFunction) {
523         super.swap(normalClass, swappedClass, swapFunction, unswapFunction);
524         return this;
525      }
526
527      @Override /* Overridden from Builder */
528      public Builder swaps(Object...values) {
529         super.swaps(values);
530         return this;
531      }
532
533      @Override /* Overridden from Builder */
534      public Builder swaps(Class<?>...values) {
535         super.swaps(values);
536         return this;
537      }
538
539      @Override /* Overridden from Builder */
540      public Builder timeZone(TimeZone value) {
541         super.timeZone(value);
542         return this;
543      }
544
545      @Override /* Overridden from Builder */
546      public Builder typeName(Class<?> on, String value) {
547         super.typeName(on, value);
548         return this;
549      }
550
551      @Override /* Overridden from Builder */
552      public Builder typePropertyName(String value) {
553         super.typePropertyName(value);
554         return this;
555      }
556
557      @Override /* Overridden from Builder */
558      public Builder typePropertyName(Class<?> on, String value) {
559         super.typePropertyName(on, value);
560         return this;
561      }
562
563      @Override /* Overridden from Builder */
564      public Builder useEnumNames() {
565         super.useEnumNames();
566         return this;
567      }
568
569      @Override /* Overridden from Builder */
570      public Builder useJavaBeanIntrospector() {
571         super.useJavaBeanIntrospector();
572         return this;
573      }
574
575      @Override /* Overridden from Builder */
576      public Builder autoCloseStreams() {
577         super.autoCloseStreams();
578         return this;
579      }
580
581      @Override /* Overridden from Builder */
582      public Builder autoCloseStreams(boolean value) {
583         super.autoCloseStreams(value);
584         return this;
585      }
586
587      @Override /* Overridden from Builder */
588      public Builder consumes(String value) {
589         super.consumes(value);
590         return this;
591      }
592
593      @Override /* Overridden from Builder */
594      public Builder debugOutputLines(int value) {
595         super.debugOutputLines(value);
596         return this;
597      }
598
599      @Override /* Overridden from Builder */
600      public Builder listener(Class<? extends org.apache.juneau.parser.ParserListener> value) {
601         super.listener(value);
602         return this;
603      }
604
605      @Override /* Overridden from Builder */
606      public Builder strict() {
607         super.strict();
608         return this;
609      }
610
611      @Override /* Overridden from Builder */
612      public Builder strict(boolean value) {
613         super.strict(value);
614         return this;
615      }
616
617      @Override /* Overridden from Builder */
618      public Builder trimStrings() {
619         super.trimStrings();
620         return this;
621      }
622
623      @Override /* Overridden from Builder */
624      public Builder trimStrings(boolean value) {
625         super.trimStrings(value);
626         return this;
627      }
628
629      @Override /* Overridden from Builder */
630      public Builder unbuffered() {
631         super.unbuffered();
632         return this;
633      }
634
635      @Override /* Overridden from Builder */
636      public Builder unbuffered(boolean value) {
637         super.unbuffered(value);
638         return this;
639      }
640
641      @Override /* Overridden from Builder */
642      public Builder binaryFormat(BinaryFormat value) {
643         super.binaryFormat(value);
644         return this;
645      }
646   }
647
648   //-------------------------------------------------------------------------------------------------------------------
649   // Instance
650   //-------------------------------------------------------------------------------------------------------------------
651
652   private final Map<ClassMeta<?>,MsgPackClassMeta> msgPackClassMetas = new ConcurrentHashMap<>();
653   private final Map<BeanPropertyMeta,MsgPackBeanPropertyMeta> msgPackBeanPropertyMetas = new ConcurrentHashMap<>();
654
655   /**
656    * Constructor.
657    *
658    * @param builder The builder for this object.
659    */
660   public MsgPackParser(Builder builder) {
661      super(builder);
662   }
663
664   @Override /* Context */
665   public Builder copy() {
666      return new Builder(this);
667   }
668
669   @Override /* Context */
670   public MsgPackParserSession.Builder createSession() {
671      return MsgPackParserSession.create(this);
672   }
673
674   @Override /* Context */
675   public MsgPackParserSession getSession() {
676      return createSession().build();
677   }
678
679   //-----------------------------------------------------------------------------------------------------------------
680   // Extended metadata
681   //-----------------------------------------------------------------------------------------------------------------
682
683   @Override /* MsgPackMetaProvider */
684   public MsgPackClassMeta getMsgPackClassMeta(ClassMeta<?> cm) {
685      MsgPackClassMeta m = msgPackClassMetas.get(cm);
686      if (m == null) {
687         m = new MsgPackClassMeta(cm, this);
688         msgPackClassMetas.put(cm, m);
689      }
690      return m;
691   }
692
693   @Override /* MsgPackMetaProvider */
694   public MsgPackBeanPropertyMeta getMsgPackBeanPropertyMeta(BeanPropertyMeta bpm) {
695      if (bpm == null)
696         return MsgPackBeanPropertyMeta.DEFAULT;
697      MsgPackBeanPropertyMeta m = msgPackBeanPropertyMetas.get(bpm);
698      if (m == null) {
699         m = new MsgPackBeanPropertyMeta(bpm.getDelegateFor(), this);
700         msgPackBeanPropertyMetas.put(bpm, m);
701      }
702      return m;
703   }
704}