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}