-
Notifications
You must be signed in to change notification settings - Fork 231
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
New ScheduledV2Event implementation #480
base: main
Are you sure you want to change the base?
Changes from 1 commit
41341c6
dbda812
1aad3e4
442ca30
a24ac32
d973523
0149926
e8852a0
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,366 @@ | ||
/* | ||
* Copyright 2012-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved. | ||
* | ||
* Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with | ||
* the License. A copy of the License is located at | ||
* | ||
* http://aws.amazon.com/apache2.0 | ||
* | ||
* or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR | ||
* CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions | ||
* and limitations under the License. | ||
*/ | ||
|
||
package com.amazonaws.services.lambda.runtime.events; | ||
|
||
import org.joda.time.DateTime; | ||
|
||
import java.io.Serializable; | ||
import java.util.List; | ||
|
||
/** | ||
* represents a scheduled V2 event | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Can you add a link to the documentation in the header please. |
||
*/ | ||
public class ScheduledV2Event implements Serializable, Cloneable { | ||
msailes marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
||
private static final long serialVersionUID = -463442139623175611L; | ||
|
||
private String version; | ||
|
||
private String account; | ||
|
||
private String region; | ||
|
||
private String detail; | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I think we (AWS) needs to validate that there will be no events where detail will be anything other than a String for scheduled task use cases. |
||
|
||
private String detailType; | ||
|
||
private String source; | ||
|
||
private String id; | ||
|
||
private DateTime time; | ||
|
||
private List<String> resources; | ||
|
||
/** | ||
* default constructor | ||
*/ | ||
public ScheduledV2Event() { | ||
} | ||
|
||
/** | ||
* @return the version number | ||
*/ | ||
public String getVersion() { | ||
return version; | ||
} | ||
|
||
/** | ||
* @param version the version number | ||
*/ | ||
public void setVersion(String version) { | ||
this.version = version; | ||
} | ||
|
||
/** | ||
* @param version version number | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withVersion(String version) { | ||
setVersion(version); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return the account id | ||
*/ | ||
public String getAccount() { | ||
return account; | ||
} | ||
|
||
/** | ||
* @param account the account id | ||
*/ | ||
public void setAccount(String account) { | ||
this.account = account; | ||
} | ||
|
||
/** | ||
* @param account account id | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withAccount(String account) { | ||
setAccount(account); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return the aws region | ||
*/ | ||
public String getRegion() { | ||
return region; | ||
} | ||
|
||
/** | ||
* @param region the aws region | ||
*/ | ||
public void setRegion(String region) { | ||
this.region = region; | ||
} | ||
|
||
/** | ||
* @param region aws region | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withRegion(String region) { | ||
setRegion(region); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return The details of the events (usually left blank) | ||
*/ | ||
public String getDetail() { | ||
return detail; | ||
} | ||
|
||
/** | ||
* @param detail The details of the events (usually left blank) | ||
*/ | ||
public void setDetail(String detail) { | ||
this.detail = detail; | ||
} | ||
|
||
/** | ||
* @param detail details of the events (usually left blank) | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withDetail(String detail) { | ||
setDetail(detail); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return The details type - see cloud watch events for more info | ||
*/ | ||
public String getDetailType() { | ||
return detailType; | ||
} | ||
|
||
/** | ||
* @param detailType The details type - see cloud watch events for more info | ||
*/ | ||
public void setDetailType(String detailType) { | ||
this.detailType = detailType; | ||
} | ||
|
||
/** | ||
* @param detailType The details type - see cloud watch events for more info | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withDetailType(String detailType) { | ||
setDetailType(detailType); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return the source of the event | ||
*/ | ||
public String getSource() { | ||
return source; | ||
} | ||
|
||
/** | ||
* @param source the source of the event | ||
*/ | ||
public void setSource(String source) { | ||
this.source = source; | ||
} | ||
|
||
/** | ||
* @param source source of the event | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withSource(String source) { | ||
setSource(source); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return the timestamp for when the event is scheduled | ||
*/ | ||
public DateTime getTime() { | ||
return this.time; | ||
} | ||
|
||
/** | ||
* @param time the timestamp for when the event is scheduled | ||
*/ | ||
public void setTime(DateTime time) { | ||
this.time = time; | ||
} | ||
|
||
/** | ||
* @param time the timestamp for when the event is scheduled | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withTime(DateTime time) { | ||
setTime(time); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return the id of the event | ||
*/ | ||
public String getId() { | ||
return id; | ||
} | ||
|
||
/** | ||
* @param id the id of the event | ||
*/ | ||
public void setId(String id) { | ||
this.id = id; | ||
} | ||
|
||
/** | ||
* @param id id of event | ||
* @return ScheduledV2Event | ||
*/ | ||
public ScheduledV2Event withId(String id) { | ||
setId(id); | ||
return this; | ||
} | ||
|
||
/** | ||
* @return the resources used by event | ||
*/ | ||
public List<String> getResources() { | ||
return this.resources; | ||
} | ||
|
||
/** | ||
* @param resources the resources used by event | ||
*/ | ||
public void setResources(List<String> resources) { | ||
this.resources = resources; | ||
} | ||
|
||
/** | ||
* @param resources list of resource names | ||
* @return Scheduled V2 event object | ||
*/ | ||
public ScheduledV2Event withResources(List<String> resources) { | ||
setResources(resources); | ||
return this; | ||
} | ||
|
||
/** | ||
* Returns a string representation of this object; useful for testing and debugging. | ||
* | ||
* @return A string representation of this object. | ||
* @see Object#toString() | ||
*/ | ||
@Override | ||
public String toString() { | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. https://projectlombok.org/features/Data includes toString, hashcode and equals, you can remove those, and the clone method. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Done. |
||
StringBuilder sb = new StringBuilder(); | ||
sb.append("{"); | ||
if (getVersion() != null) | ||
sb.append("version: ").append(getVersion()).append(","); | ||
if (getAccount() != null) | ||
sb.append("account: ").append(getAccount()).append(","); | ||
if (getRegion() != null) | ||
sb.append("region: ").append(getRegion()).append(","); | ||
if (getDetail() != null) | ||
sb.append("detail: ").append(getDetail()).append(","); | ||
if (getDetailType() != null) | ||
sb.append("detailType: ").append(getDetailType()).append(","); | ||
if (getSource() != null) | ||
sb.append("source: ").append(getSource()).append(","); | ||
if (getId() != null) | ||
sb.append("id: ").append(getId()).append(","); | ||
if (getTime() != null) | ||
sb.append("time: ").append(getTime().toString()).append(","); | ||
if (getResources() != null) | ||
sb.append("resources: ").append(getResources()); | ||
sb.append("}"); | ||
return sb.toString(); | ||
} | ||
|
||
@Override | ||
public boolean equals(Object obj) { | ||
if (this == obj) | ||
return true; | ||
if (obj == null) | ||
return false; | ||
|
||
if (obj instanceof ScheduledV2Event == false) | ||
return false; | ||
ScheduledV2Event other = (ScheduledV2Event) obj; | ||
if (other.getVersion() == null ^ this.getVersion() == null) | ||
return false; | ||
if (other.getVersion() != null && other.getVersion().equals(this.getVersion()) == false) | ||
return false; | ||
if (other.getAccount() == null ^ this.getAccount() == null) | ||
return false; | ||
if (other.getAccount() != null && other.getAccount().equals(this.getAccount()) == false) | ||
return false; | ||
if (other.getRegion() == null ^ this.getRegion() == null) | ||
return false; | ||
if (other.getRegion() != null && other.getRegion().equals(this.getRegion()) == false) | ||
return false; | ||
if (other.getDetail() == null ^ this.getDetail() == null) | ||
return false; | ||
if (other.getDetail() != null && other.getDetail().equals(this.getDetail()) == false) | ||
return false; | ||
if (other.getDetailType() == null ^ this.getDetailType() == null) | ||
return false; | ||
if (other.getDetailType() != null && other.getDetailType().equals(this.getDetailType()) == false) | ||
return false; | ||
if (other.getSource() == null ^ this.getSource() == null) | ||
return false; | ||
if (other.getSource() != null && other.getSource().equals(this.getSource()) == false) | ||
return false; | ||
if (other.getId() == null ^ this.getId() == null) | ||
return false; | ||
if (other.getId() != null && other.getId().equals(this.getId()) == false) | ||
return false; | ||
if (other.getTime() == null ^ this.getTime() == null) | ||
return false; | ||
if (other.getTime() != null && other.getTime().equals(this.getTime()) == false) | ||
return false; | ||
if (other.getResources() == null ^ this.getResources() == null) | ||
return false; | ||
if (other.getResources() != null && other.getResources().equals(this.getResources()) == false) | ||
return false; | ||
return true; | ||
} | ||
|
||
@Override | ||
public int hashCode() { | ||
final int prime = 31; | ||
int hashCode = 1; | ||
|
||
hashCode = prime * hashCode + ((getVersion() == null) ? 0 : getVersion().hashCode()); | ||
hashCode = prime * hashCode + ((getAccount() == null) ? 0 : getAccount().hashCode()); | ||
hashCode = prime * hashCode + ((getRegion() == null) ? 0 : getRegion().hashCode()); | ||
hashCode = prime * hashCode + ((getDetail() == null) ? 0 : getDetail().hashCode()); | ||
hashCode = prime * hashCode + ((getDetailType() == null) ? 0 : getDetailType().hashCode()); | ||
hashCode = prime * hashCode + ((getSource() == null) ? 0 : getSource().hashCode()); | ||
hashCode = prime * hashCode + ((getId() == null) ? 0 : getId().hashCode()); | ||
hashCode = prime * hashCode + ((getTime() == null) ? 0 : getTime().hashCode()); | ||
hashCode = prime * hashCode + ((getResources() == null) ? 0 : getResources().hashCode()); | ||
return hashCode; | ||
} | ||
|
||
@Override | ||
public ScheduledV2Event clone() { | ||
try { | ||
return (ScheduledV2Event) super.clone(); | ||
} catch (CloneNotSupportedException e) { | ||
throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone()", e); | ||
} | ||
} | ||
|
||
} |
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,8 +1,10 @@ | ||
package com.amazonaws.services.lambda.runtime.events; | ||
|
||
import org.junit.jupiter.api.BeforeAll; | ||
import org.junit.jupiter.api.Test; | ||
|
||
import java.time.Instant; | ||
import java.util.Locale; | ||
|
||
import static org.junit.jupiter.api.Assertions.assertEquals; | ||
import static org.junit.jupiter.api.Assertions.assertNotNull; | ||
|
@@ -12,6 +14,11 @@ public class APIGatewayV2CustomAuthorizerEventTest { | |
private static final long TIME_EPOCH = 1601306426515L; | ||
private static final String TIME = "28/Sep/2020:15:14:43 +0000"; | ||
|
||
@BeforeAll | ||
static void beforeAll() { | ||
Locale.setDefault(new Locale("en", "US")); | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. thanks for this |
||
} | ||
|
||
@Test | ||
public void testEpochLongAsAnInstant() { | ||
APIGatewayV2CustomAuthorizerEvent customAuthorizerEvent = APIGatewayV2CustomAuthorizerEvent.builder() | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please update the header to